Skip to content

feat: upgrade docker-compose.yml stable image tags#4182

Merged
jgao54 merged 1 commit intomainfrom
automated/docker-compose-image-tags-upgrade-v0.36.17
Apr 16, 2026
Merged

feat: upgrade docker-compose.yml stable image tags#4182
jgao54 merged 1 commit intomainfrom
automated/docker-compose-image-tags-upgrade-v0.36.17

Conversation

@github-actions
Copy link
Copy Markdown
Contributor

No description provided.

@github-actions github-actions bot added the dependencies Pull requests that update a dependency file label Apr 15, 2026
@github-actions github-actions bot enabled auto-merge (squash) April 15, 2026 22:52
@jgao54 jgao54 disabled auto-merge April 16, 2026 01:30
@jgao54 jgao54 closed this Apr 16, 2026
@jgao54 jgao54 reopened this Apr 16, 2026
@jgao54 jgao54 enabled auto-merge (squash) April 16, 2026 01:31
@codecov
Copy link
Copy Markdown

codecov bot commented Apr 16, 2026

❌ 2 Tests Failed:

Tests completed Failed Passed Skipped
2224 2 2222 187
View the top 3 failed test(s) by shortest run time
github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg
Stack Traces | 0.01s run time
=== RUN   TestApiPg
=== PAUSE TestApiPg
=== CONT  TestApiPg
--- FAIL: TestApiPg (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ
Stack Traces | 0.01s run time
=== RUN   TestGenericBQ
=== PAUSE TestGenericBQ
=== CONT  TestGenericBQ
--- FAIL: TestGenericBQ (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH
=== PAUSE TestPeerFlowE2ETestSuitePG_CH
=== CONT  TestPeerFlowE2ETestSuitePG_CH
--- FAIL: TestPeerFlowE2ETestSuitePG_CH (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestResyncCompleted
Stack Traces | 0.09s run time
=== RUN   TestApiPg/TestResyncCompleted
=== PAUSE TestApiPg/TestResyncCompleted
=== CONT  TestApiPg/TestResyncCompleted
2026/04/16 01:41:13 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/16 01:41:13 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:1301: 
        	Error Trace:	.../flow/e2e/api_test.go:1301
        	Error:      	Received unexpected error:
        	            	failed to get workflow_id for flow resync_completed_api_osreu9mi: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
        	Test:       	TestApiPg/TestResyncCompleted
    api_test.go:48: begin tearing down postgres schema api_osreu9mi
--- FAIL: TestApiPg/TestResyncCompleted (0.09s)
github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
Stack Traces | 34.3s run time
=== RUN   TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
=== PAUSE TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
=== CONT  TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting
    generic_test.go:1103: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    bigquery.go:86: begin tearing down postgres schema bq_hftjdlh8_20260416020250
2026/04/16 02:03:23 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id"
2026/04/16 02:03:23 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id"
2026/04/16 02:03:23 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16111495259925013628 CURSOR FOR SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/16 02:03:23 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/16 02:03:23 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16111495259925013628
2026/04/16 02:03:23 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16111495259925013628 records=2 bytes=12 channelLen=1
2026/04/16 02:03:23 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=1
2026/04/16 02:03:23 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16111495259925013628
2026/04/16 02:03:23 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16111495259925013628 records=0 bytes=0 channelLen=0
2026/04/16 02:03:23 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 02:03:23 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 02:03:23 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_bq_mycqas5g_20260416020224.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
--- FAIL: TestGenericBQ/Test_Inheritance_Table_With_Dynamic_Setting (34.31s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
Stack Traces | 173s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
=== PAUSE TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
=== CONT  TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
2026/04/16 01:41:24 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id"
2026/04/16 01:41:24 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id"
2026/04/16 01:41:24 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13294552227206103822 CURSOR FOR SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id" args=[]
2026/04/16 01:41:24 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id" channelLen=0
2026/04/16 01:41:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13294552227206103822
2026/04/16 01:41:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13294552227206103822 records=1 bytes=20 channelLen=0
2026/04/16 01:41:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=1 bytes=20 channelLen=0
2026/04/16 01:41:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13294552227206103822
2026/04/16 01:41:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13294552227206103822 records=0 bytes=0 channelLen=0
2026/04/16 01:41:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 01:41:24 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 01:41:24 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"Ac1\",c2,\"Ac3\",c4,\"Ac5\" FROM e2e_test_pgch_putox62k.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=1 bytes=20 channelLen=0
2026/04/16 01:41:24 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    clickhouse_test.go:2208: WaitFor waiting on initial 2026-04-16 01:41:30.314210204 +0000 UTC m=+401.870989745
2026/04/16 01:41:30 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id"
2026/04/16 01:41:30 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id"
2026/04/16 01:41:30 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_878767317506211163 CURSOR FOR SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id" args=[]
2026/04/16 01:41:30 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id" channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_878767317506211163
2026/04/16 01:41:30 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_878767317506211163 records=4 bytes=29 channelLen=3
2026/04/16 01:41:30 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id" rows=4 bytes=29 channelLen=3
2026/04/16 01:41:30 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_878767317506211163
2026/04/16 01:41:30 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_878767317506211163 records=0 bytes=0 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 01:41:30 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_216hjf7l.\"test_normalize_metadata_with_retry_1\" ORDER BY id" rows=4 bytes=29 channelLen=0
    clickhouse_test.go:2222: WaitFor waiting for first sync to complete 2026-04-16 01:41:30.334040836 +0000 UTC m=+401.890820387
2026/04/16 01:41:30 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id"
2026/04/16 01:41:30 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id"
2026/04/16 01:41:30 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17582839205276518231 CURSOR FOR SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id" args=[]
2026/04/16 01:41:30 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id" channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17582839205276518231
2026/04/16 01:41:30 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17582839205276518231 records=1 bytes=16 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=1 bytes=16 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17582839205276518231
2026/04/16 01:41:30 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17582839205276518231 records=0 bytes=0 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 01:41:30 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 01:41:30 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,\"Ac2\",\"Ac3\",c4 FROM e2e_test_pgch_qox0yy0n.\"test_nullable_sc_ch_replident_full\" ORDER BY id" rows=1 bytes=16 channelLen=0
    clickhouse_test.go:2233: WaitFor waiting for raw table push to complete 2026-04-16 01:41:46.347972165 +0000 UTC m=+417.904751706
2026/04/16 01:41:46 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id"
2026/04/16 01:41:46 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id"
2026/04/16 01:41:46 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_1733968648174101917 CURSOR FOR SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id" args=[]
2026/04/16 01:41:46 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id" channelLen=0
    clickhouse_test.go:2246: WaitFor waiting for normalize error 2026-04-16 01:41:46.351566868 +0000 UTC m=+417.908346409
2026/04/16 01:41:46 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1733968648174101917
2026/04/16 01:41:46 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1733968648174101917 records=2 bytes=8 channelLen=1
2026/04/16 01:41:46 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id" rows=2 bytes=8 channelLen=1
2026/04/16 01:41:46 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1733968648174101917
2026/04/16 01:41:46 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1733968648174101917 records=0 bytes=0 channelLen=0
2026/04/16 01:41:46 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 01:41:46 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 01:41:46 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id FROM e2e_test_pgch_3hcom3wi.\"test_json_null\" ORDER BY id" rows=2 bytes=8 channelLen=0
    clickhouse_test.go:2259: WaitFor waiting for second sync to complete 2026-04-16 01:41:46.358762415 +0000 UTC m=+417.915541956
    clickhouse_test.go:2270: WaitFor waiting for second raw table push to complete 2026-04-16 01:42:01.371282202 +0000 UTC m=+432.928061743
    clickhouse.go:115: 
        	Error Trace:	.../flow/e2e/congen.go:43
        	            				.../flow/e2e/clickhouse.go:115
        	            				.../flow/e2e/clickhouse.go:97
        	            				.../flow/e2e/clickhouse.go:172
        	            				.../flow/e2e/clickhouse_test.go:2271
        	            				.../flow/e2e/test_utils.go:852
        	            				.../flow/e2e/clickhouse_test.go:2270
        	Error:      	Received unexpected error:
        	            	unable to establish connection with catalog: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
        	Test:       	TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
    clickhouse.go:125: begin tearing down postgres schema pgch_216hjf7l
2026/04/16 01:42:17 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id"
2026/04/16 01:42:17 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id"
2026/04/16 01:42:17 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6552557939980001291 CURSOR FOR SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id" args=[]
2026/04/16 01:42:17 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id" channelLen=0
2026/04/16 01:42:17 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6552557939980001291
2026/04/16 01:42:17 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6552557939980001291 records=2 bytes=19 channelLen=1
2026/04/16 01:42:17 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/04/16 01:42:17 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6552557939980001291
2026/04/16 01:42:17 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6552557939980001291 records=0 bytes=0 channelLen=0
2026/04/16 01:42:17 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/16 01:42:17 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/16 01:42:17 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_srdbi3gm.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    clickhouse.go:125: 
        	Error Trace:	.../flow/e2e/pg.go:148
        	            				.../flow/e2e/clickhouse.go:125
        	            				.../flow/e2eshared/e2eshared.go:38
        	            				.../hostedtoolcache/go/1.26.1.../src/testing/testing.go:1317
        	            				.../hostedtoolcache/go/1.26.1.../src/testing/testing.go:1667
        	            				.../hostedtoolcache/go/1.26.1.../src/testing/testing.go:2030
        	            				.../hostedtoolcache/go/1.26.1.../src/runtime/panic.go:694
        	            				.../hostedtoolcache/go/1.26.1.../src/testing/testing.go:1022
        	            				.../flow/e2e/congen.go:43
        	            				.../flow/e2e/clickhouse.go:115
        	            				.../flow/e2e/clickhouse.go:97
        	            				.../flow/e2e/clickhouse.go:172
        	            				.../flow/e2e/clickhouse_test.go:2271
        	            				.../flow/e2e/test_utils.go:852
        	            				.../flow/e2e/clickhouse_test.go:2270
        	            				.../hostedtoolcache/go/1.26.1.../src/reflect/value.go:369
        	            				.../flow/e2eshared/e2eshared.go:40
        	Error:      	failed to teardown postgres schema
        	Test:       	TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry
        	Messages:   	pgch_216hjf7l: failed to drop replication slots: ERROR: replication slot "peerflow_slot_test_normalize_metadata_with_retry_pgch_216hjf7l" is active for PID 17057 (SQLSTATE 55006)
--- FAIL: TestPeerFlowE2ETestSuitePG_CH/Test_Normalize_Metadata_With_Retry (173.47s)

To view more test analytics, go to the Test Analytics Dashboard
📋 Got 3 mins? Take this short survey to help us improve Test Analytics.

@github-actions
Copy link
Copy Markdown
Contributor Author

🔄 Flaky Test Detected

Analysis: Both failures are infrastructure/timing errors — one is a PostgreSQL connection killed by admin command (SQLSTATE 57P01) and the other is an async normalization timeout with a teardown panic — neither indicates a code regression.
Confidence: 0.93

✅ Automatically retrying the workflow

View workflow run

@github-actions
Copy link
Copy Markdown
Contributor Author

❌ Test Failure

Analysis: BigQuery e2e tests consistently fail with Unrecognized name: extra at [1:32], invalidQuery across all matrix configurations, indicating a real bug where a column named extra is referenced in queries but does not exist in the destination schema; this causes tests to hang (likely due to the recent retryable-error change in #4181), cascading into a full 900s suite timeout in the maria job.
Confidence: 0.82

⚠️ This appears to be a real bug - manual intervention needed

View workflow run

@jgao54 jgao54 merged commit 086523b into main Apr 16, 2026
16 of 20 checks passed
@jgao54 jgao54 deleted the automated/docker-compose-image-tags-upgrade-v0.36.17 branch April 16, 2026 05:03
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

dependencies Pull requests that update a dependency file

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant