Skip to content

CI Tests results ingestion: Follow-up improvements#4209

Merged
pfcoperez merged 3 commits into
mainfrom
DBI-671/test/o11y/add-matrix-configuration-id
Apr 21, 2026
Merged

CI Tests results ingestion: Follow-up improvements#4209
pfcoperez merged 3 commits into
mainfrom
DBI-671/test/o11y/add-matrix-configuration-id

Conversation

@pfcoperez

@pfcoperez pfcoperez commented Apr 21, 2026

Copy link
Copy Markdown
Member

Two improvements following up #4191

  1. Include information on the sources versions matrix combination.
  2. For PRs, the commit information is now the last commit pushed by the author rather than the resulting commit from the automatic merge from main.

@pfcoperez pfcoperez self-assigned this Apr 21, 2026
@codecov

codecov Bot commented Apr 21, 2026 •
edited
Loading

Copy link
Copy Markdown

❌ 2 Tests Failed:

Tests completed Failed Passed Skipped
2220 2 2218 201
View the top 3 failed test(s) by shortest run time 
github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ
Stack Traces | 0s run time 
=== RUN   TestGenericBQ
=== PAUSE TestGenericBQ
=== CONT  TestGenericBQ
--- FAIL: TestGenericBQ (0.00s)

github.com/PeerDB-io/peerdb/flow/e2e::TestMongoClickhouseSuite
Stack Traces | 0s run time 
=== RUN   TestMongoClickhouseSuite
=== PAUSE TestMongoClickhouseSuite
=== CONT  TestMongoClickhouseSuite
--- FAIL: TestMongoClickhouseSuite (0.00s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiMy
Stack Traces | 0.01s run time 
=== RUN   TestApiMy
=== PAUSE TestApiMy
=== CONT  TestApiMy
--- FAIL: TestApiMy (0.01s)

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::TestGenericCH_MySQL
Stack Traces | 0.01s run time 
=== RUN   TestGenericCH_MySQL
=== PAUSE TestGenericCH_MySQL
=== CONT  TestGenericCH_MySQL
--- FAIL: TestGenericCH_MySQL (0.01s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteBQ
Stack Traces | 0.01s run time 
=== RUN   TestPeerFlowE2ETestSuiteBQ
=== PAUSE TestPeerFlowE2ETestSuiteBQ
=== CONT  TestPeerFlowE2ETestSuiteBQ
--- FAIL: TestPeerFlowE2ETestSuiteBQ (0.01s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster
Stack Traces | 0.01s run time 
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster (0.01s)
2026/04/21 19:35:37 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_wb26vhuv.test_nullengine
2026/04/21 19:35:37 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_i7fet4d2.test_exclude_ch

github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestPostgresDestinationValidation_MissingColumns
Stack Traces | 0.04s run time 
=== RUN   TestApiPg/TestPostgresDestinationValidation_MissingColumns
=== PAUSE TestApiPg/TestPostgresDestinationValidation_MissingColumns
=== CONT  TestApiPg/TestPostgresDestinationValidation_MissingColumns
2026/04/21 19:13:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_ju54kgwm.\"test_nullengine\" ORDER BY id"
2026/04/21 19:13:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_ju54kgwm.\"test_nullengine\" ORDER BY id"
2026/04/21 19:13:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16794436637502315504 CURSOR FOR SELECT id,\"key\" FROM e2e_test_pgch_ju54kgwm.\"test_nullengine\" ORDER BY id" args=[]
2026/04/21 19:13:22 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_ju54kgwm.\"test_nullengine\" ORDER BY id" channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16794436637502315504
2026/04/21 19:13:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16794436637502315504 records=3 bytes=26 channelLen=2
2026/04/21 19:13:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_ju54kgwm.\"test_nullengine\" ORDER BY id" rows=3 bytes=26 channelLen=2
2026/04/21 19:13:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16794436637502315504
2026/04/21 19:13:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16794436637502315504 records=0 bytes=0 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_ju54kgwm.\"test_nullengine\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:13:22 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_ju54kgwm.\"test_nullengine\" ORDER BY id" rows=3 bytes=26 channelLen=0
    clickhouse.go:115: 
        	Error Trace:	.../flow/e2e/congen.go:44
        	            				.../flow/e2e/clickhouse.go:115
        	            				.../flow/e2e/clickhouse.go:97
        	            				.../flow/e2e/clickhouse.go:432
        	            				.../flow/e2e/api_test.go:232
        	            				.../flow/e2eshared/e2eshared.go:34
        	Error:      	Received unexpected error:
        	            	unable to establish connection with catalog: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
        	Test:       	TestApiPg/TestPostgresDestinationValidation_MissingColumns
--- FAIL: TestApiPg/TestPostgresDestinationValidation_MissingColumns (0.04s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericCH_MySQL/Test_Schema_Change_Lost_Column_Bug
Stack Traces | 5.02s run time 
=== RUN   TestGenericCH_MySQL/Test_Schema_Change_Lost_Column_Bug
=== PAUSE TestGenericCH_MySQL/Test_Schema_Change_Lost_Column_Bug
=== CONT  TestGenericCH_MySQL/Test_Schema_Change_Lost_Column_Bug
2026/04/21 19:47:46 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:47:46 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    generic_test.go:722: Failed to connect temporal client: failed reaching server: context deadline exceeded
--- FAIL: TestGenericCH_MySQL/Test_Schema_Change_Lost_Column_Bug (5.02s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiMy/TestCancelTableAddition_WithRemoval
Stack Traces | 18.1s run time 
=== RUN   TestApiMy/TestCancelTableAddition_WithRemoval
=== PAUSE TestApiMy/TestCancelTableAddition_WithRemoval
=== CONT  TestApiMy/TestCancelTableAddition_WithRemoval
2026/04/21 19:45:24 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:45:24 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:45:24 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id"
2026/04/21 19:45:24 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id"
2026/04/21 19:45:24 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_2585168818089565211 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" args=[]
2026/04/21 19:45:24 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2585168818089565211
2026/04/21 19:45:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2585168818089565211 records=8 bytes=168 channelLen=7
2026/04/21 19:45:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=8 bytes=168 channelLen=7
2026/04/21 19:45:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2585168818089565211
2026/04/21 19:45:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2585168818089565211 records=0 bytes=0 channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:45:24 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=8 bytes=168 channelLen=0
2026/04/21 19:45:24 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id"
2026/04/21 19:45:24 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id"
2026/04/21 19:45:24 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4770694796829400916 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/21 19:45:24 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4770694796829400916
2026/04/21 19:45:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4770694796829400916 records=13 bytes=293 channelLen=12
2026/04/21 19:45:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/21 19:45:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4770694796829400916
2026/04/21 19:45:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4770694796829400916 records=0 bytes=0 channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:45:24 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:45:24 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=0
    cancel_table_addition_test.go:361: WaitFor wait for initial load to finish 2026-04-21 19:45:32.720883936 +0000 UTC m=+213.829723264
    cancel_table_addition_test.go:365: WaitFor t1 initial load 2026-04-21 19:45:32.721265864 +0000 UTC m=+213.830105192
2026/04/21 19:45:32 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_nboyndcg.t1
    cancel_table_addition_test.go:366: WaitFor t2 initial load 2026-04-21 19:45:32.727299219 +0000 UTC m=+213.836138547
2026/04/21 19:45:32 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_nboyndcg.t2
    cancel_table_addition_test.go:367: WaitFor t3 initial load 2026-04-21 19:45:32.731778737 +0000 UTC m=+213.840618065
2026/04/21 19:45:32 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_nboyndcg.t3
    cancel_table_addition_test.go:375: WaitFor wait for pause for add table 2026-04-21 19:45:32.73998987 +0000 UTC m=+213.848829198
2026/04/21 19:45:32 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id"
2026/04/21 19:45:32 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id"
2026/04/21 19:45:32 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id"
2026/04/21 19:45:32 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id"
2026/04/21 19:45:32 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_760253408479919955 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/21 19:45:32 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10869023661905999825 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" args=[]
2026/04/21 19:45:32 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_760253408479919955
2026/04/21 19:45:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_760253408479919955 records=13 bytes=293 channelLen=12
2026/04/21 19:45:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/21 19:45:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_760253408479919955
2026/04/21 19:45:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_760253408479919955 records=0 bytes=0 channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:45:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10869023661905999825
2026/04/21 19:45:32 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_2tpxueer.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=0
2026/04/21 19:45:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10869023661905999825 records=8 bytes=168 channelLen=7
2026/04/21 19:45:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=8 bytes=168 channelLen=7
2026/04/21 19:45:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10869023661905999825
2026/04/21 19:45:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10869023661905999825 records=0 bytes=0 channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:45:32 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:45:32 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pgchclg_gjmsly9f.\"test_inheritance_dynconf\" ORDER BY id" rows=8 bytes=168 channelLen=0
    cancel_table_addition_test.go:376: UNEXPECTED ERROR unable to establish connection with catalog: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
    api_test.go:48: begin tearing down postgres schema api_nboyndcg
--- FAIL: TestApiMy/TestCancelTableAddition_WithRemoval (18.15s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestTableAdditionWithoutInitialLoad
Stack Traces | 19.2s run time 
=== RUN   TestApiPg/TestTableAdditionWithoutInitialLoad
=== PAUSE TestApiPg/TestTableAdditionWithoutInitialLoad
=== CONT  TestApiPg/TestTableAdditionWithoutInitialLoad
2026/04/21 19:13:18 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:13:18 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:2278: WaitFor wait for initial load to finish 2026-04-21 19:13:22.740103636 +0000 UTC m=+444.643620401
2026/04/21 19:13:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_l0terp3q.\"original\" ORDER BY id"
2026/04/21 19:13:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_l0terp3q.\"original\" ORDER BY id"
2026/04/21 19:13:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_12802947972488999062 CURSOR FOR SELECT id,val FROM e2e_test_api_l0terp3q.\"original\" ORDER BY id" args=[]
2026/04/21 19:13:22 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_l0terp3q.\"original\" ORDER BY id" channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12802947972488999062
2026/04/21 19:13:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12802947972488999062 records=1 bytes=9 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_l0terp3q.\"original\" ORDER BY id" rows=1 bytes=9 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12802947972488999062
2026/04/21 19:13:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12802947972488999062 records=0 bytes=0 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_l0terp3q.\"original\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:13:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:13:22 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_l0terp3q.\"original\" ORDER BY id" rows=1 bytes=9 channelLen=0
    api_test.go:2288: WaitFor wait for pause for add table 2026-04-21 19:13:22.758761011 +0000 UTC m=+444.662277766
2026/04/21 19:13:23 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_nh5kzs3h.t1
    api_test.go:2289: UNEXPECTED ERROR unable to establish connection with catalog: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
    api_test.go:48: begin tearing down postgres schema api_l0terp3q
2026/04/21 19:13:28 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_api_nh5kzs3h.t1
--- FAIL: TestApiPg/TestTableAdditionWithoutInitialLoad (19.16s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericBQ/Test_Simple_Flow
Stack Traces | 33.8s run time 
=== RUN   TestGenericBQ/Test_Simple_Flow
=== PAUSE TestGenericBQ/Test_Simple_Flow
=== CONT  TestGenericBQ/Test_Simple_Flow
2026/04/21 19:28:39 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id"
2026/04/21 19:28:39 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id"
2026/04/21 19:28:39 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9974636206009778516 CURSOR FOR SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id" args=[]
2026/04/21 19:28:39 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id" channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9974636206009778516
2026/04/21 19:28:39 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9974636206009778516 records=1 bytes=21 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id" rows=1 bytes=21 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9974636206009778516
2026/04/21 19:28:39 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9974636206009778516 records=0 bytes=0 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:28:39 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM ONLY e2e_test_pg_quv2be5v.\"test_inheritance\" ORDER BY id" rows=1 bytes=21 channelLen=0
2026/04/21 19:28:39 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id"
2026/04/21 19:28:39 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id"
2026/04/21 19:28:39 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16302817916283019983 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id" args=[]
2026/04/21 19:28:39 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id" channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16302817916283019983
2026/04/21 19:28:39 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16302817916283019983 records=0 bytes=0 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:28:39 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:28:39 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_pg_quv2be5v.\"test_inheritance_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
    generic_test.go:124: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    bigquery.go:86: begin tearing down postgres schema bq_kh5lycvl_20260421192839
--- FAIL: TestGenericBQ/Test_Simple_Flow (33.75s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
Stack Traces | 134s run time 
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
2026/04/21 19:33:22 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:33:22 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:33:22 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    clickhouse_test.go:1064: WaitFor waiting for CDC count 2026-04-21 19:33:26.800618822 +0000 UTC m=+585.828273524
    clickhouse_test.go:1068: WaitFor waiting for CDC count 2026-04-21 19:33:26.811554784 +0000 UTC m=+585.839209496
    clickhouse.go:94: 
        	Error Trace:	.../flow/e2e/congen.go:44
        	            				.../flow/e2e/clickhouse.go:94
        	            				.../flow/e2e/clickhouse.go:172
        	            				.../flow/e2e/test_utils.go:240
        	            				.../flow/e2e/test_utils.go:852
        	            				.../flow/e2e/test_utils.go:237
        	            				.../flow/e2e/clickhouse_test.go:1068
        	            				.../flow/e2e/clickhouse_test.go:1083
        	Error:      	Received unexpected error:
        	            	unable to establish connection with catalog: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
        	Test:       	TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
    clickhouse.go:125: begin tearing down postgres schema pgchcl_u2mqnxk5
    clickhouse.go:125: 
        	Error Trace:	.../flow/e2e/pg.go:148
        	            				.../flow/e2e/clickhouse.go:125
        	            				.../flow/e2eshared/e2eshared.go:38
        	            				.../hostedtoolcache/go/1.26.2.../src/testing/testing.go:1317
        	            				.../hostedtoolcache/go/1.26.2.../src/testing/testing.go:1667
        	            				.../hostedtoolcache/go/1.26.2.../src/testing/testing.go:2030
        	            				.../hostedtoolcache/go/1.26.2.../src/runtime/panic.go:694
        	            				.../hostedtoolcache/go/1.26.2.../src/testing/testing.go:1022
        	            				.../flow/e2e/congen.go:44
        	            				.../flow/e2e/clickhouse.go:94
        	            				.../flow/e2e/clickhouse.go:172
        	            				.../flow/e2e/test_utils.go:240
        	            				.../flow/e2e/test_utils.go:852
        	            				.../flow/e2e/test_utils.go:237
        	            				.../flow/e2e/clickhouse_test.go:1068
        	            				.../flow/e2e/clickhouse_test.go:1083
        	            				.../hostedtoolcache/go/1.26.2.../src/reflect/value.go:586
        	            				.../hostedtoolcache/go/1.26.2.../src/reflect/value.go:369
        	            				.../flow/e2eshared/e2eshared.go:40
        	Error:      	failed to teardown postgres schema
        	Test:       	TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw
        	Messages:   	pgchcl_u2mqnxk5: failed to drop replication slots: ERROR: replication slot "peerflow_slot_ch_binary_format_raw_pgchcl_u2mqnxk5" is active for PID 28534 (SQLSTATE 55006)
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_Binary_Format_Raw (134.49s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteBQ/Test_Types
Stack Traces | 142s run time 
=== RUN   TestPeerFlowE2ETestSuiteBQ/Test_Types
=== PAUSE TestPeerFlowE2ETestSuiteBQ/Test_Types
=== CONT  TestPeerFlowE2ETestSuiteBQ/Test_Types
    bigquery_test.go:405: WaitFor normalize types 2026-04-21 19:31:55.662975711 +0000 UTC m=+481.023540075
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:31:56 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id"
2026/04/21 19:31:56 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id"
2026/04/21 19:31:56 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8158218758450878004 CURSOR FOR SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id" args=[]
2026/04/21 19:31:56 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id" channelLen=0
2026/04/21 19:31:56 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8158218758450878004
2026/04/21 19:31:56 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8158218758450878004 records=10 bytes=660 channelLen=9
2026/04/21 19:31:56 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id" rows=10 bytes=660 channelLen=9
2026/04/21 19:31:56 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8158218758450878004
2026/04/21 19:31:56 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8158218758450878004 records=0 bytes=0 channelLen=0
2026/04/21 19:31:56 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:31:56 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:31:56 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,key,value,j FROM e2e_test_bq_5t5lgcz5_20260421193134.\"test_json_pkey_bq\" ORDER BY id" rows=10 bytes=660 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:00 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:00 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:00 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10160146542352705727 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" args=[]
2026/04/21 19:32:00 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" channelLen=0
2026/04/21 19:32:00 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10160146542352705727
2026/04/21 19:32:00 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10160146542352705727 records=1 bytes=8870 channelLen=0
2026/04/21 19:32:00 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
2026/04/21 19:32:00 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10160146542352705727
2026/04/21 19:32:00 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10160146542352705727 records=0 bytes=0 channelLen=0
2026/04/21 19:32:00 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:00 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:00 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:02 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id"
2026/04/21 19:32:02 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id"
2026/04/21 19:32:02 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_12670362545540805219 CURSOR FOR SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id" args=[]
2026/04/21 19:32:02 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id" channelLen=0
2026/04/21 19:32:02 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12670362545540805219
2026/04/21 19:32:02 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12670362545540805219 records=5 bytes=44411 channelLen=0
2026/04/21 19:32:02 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id" rows=5 bytes=44411 channelLen=0
2026/04/21 19:32:02 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12670362545540805219
2026/04/21 19:32:02 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12670362545540805219 records=0 bytes=0 channelLen=0
2026/04/21 19:32:02 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:02 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:02 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t,t2 FROM e2e_test_bq_x2b6axvh_20260421193132.\"test_cpkey_toast1\" ORDER BY id" rows=5 bytes=44411 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:08 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:08 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:08 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_11719629431316865391 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" args=[]
2026/04/21 19:32:08 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" channelLen=0
2026/04/21 19:32:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11719629431316865391
2026/04/21 19:32:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11719629431316865391 records=1 bytes=8870 channelLen=0
2026/04/21 19:32:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
2026/04/21 19:32:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11719629431316865391
2026/04/21 19:32:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11719629431316865391 records=0 bytes=0 channelLen=0
2026/04/21 19:32:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:08 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:08 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:10 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id"
2026/04/21 19:32:10 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id"
2026/04/21 19:32:10 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9017640637879637368 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id" args=[]
2026/04/21 19:32:10 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id" channelLen=0
2026/04/21 19:32:10 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9017640637879637368
2026/04/21 19:32:10 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9017640637879637368 records=10 bytes=240 channelLen=9
2026/04/21 19:32:10 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id" rows=10 bytes=240 channelLen=9
2026/04/21 19:32:10 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9017640637879637368
2026/04/21 19:32:10 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9017640637879637368 records=0 bytes=0 channelLen=0
2026/04/21 19:32:10 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:10 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:10 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_norebkkc_20260421193142.\"test_simple_cpkey\" ORDER BY id" rows=10 bytes=240 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:14 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id"
2026/04/21 19:32:14 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id"
2026/04/21 19:32:14 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10129001562972917159 CURSOR FOR SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:32:14 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:32:14 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10129001562972917159
2026/04/21 19:32:14 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10129001562972917159 records=2 bytes=243 channelLen=1
2026/04/21 19:32:14 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id" rows=2 bytes=243 channelLen=0
2026/04/21 19:32:14 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10129001562972917159
2026/04/21 19:32:14 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10129001562972917159 records=0 bytes=0 channelLen=0
2026/04/21 19:32:14 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:14 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:14 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,c3,c4,c5,c6 FROM e2e_test_bq_4a2udqk4_20260421193131.\"test_all_types_schema_changes\" ORDER BY id" rows=2 bytes=243 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:20 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:32:20 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:32:20 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_405375795989212574 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" args=[]
2026/04/21 19:32:20 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" channelLen=0
2026/04/21 19:32:20 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_405375795989212574
2026/04/21 19:32:20 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_405375795989212574 records=1 bytes=8876 channelLen=0
2026/04/21 19:32:20 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=8876 channelLen=0
2026/04/21 19:32:20 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_405375795989212574
2026/04/21 19:32:20 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_405375795989212574 records=0 bytes=0 channelLen=0
2026/04/21 19:32:20 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:20 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:20 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=8876 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id"
2026/04/21 19:32:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id"
2026/04/21 19:32:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_129349721701445711 CURSOR FOR SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id" args=[]
2026/04/21 19:32:22 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id" channelLen=0
2026/04/21 19:32:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_129349721701445711
2026/04/21 19:32:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_129349721701445711 records=1 bytes=17768 channelLen=0
2026/04/21 19:32:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id" rows=1 bytes=17768 channelLen=0
2026/04/21 19:32:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_129349721701445711
2026/04/21 19:32:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_129349721701445711 records=0 bytes=0 channelLen=0
2026/04/21 19:32:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:22 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,t1,t2,k FROM e2e_test_bq_nyzu10mk_20260421193207.\"test_toast_bq_3\" ORDER BY id" rows=1 bytes=17768 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:24 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:32:24 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:32:24 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_11953856807653066913 CURSOR FOR SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:32:24 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:32:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11953856807653066913
2026/04/21 19:32:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11953856807653066913 records=1 bytes=16 channelLen=0
2026/04/21 19:32:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=16 channelLen=0
2026/04/21 19:32:24 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11953856807653066913
2026/04/21 19:32:24 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11953856807653066913 records=0 bytes=0 channelLen=0
2026/04/21 19:32:24 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:24 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:24 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=16 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:31 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:32:31 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:32:31 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_12572741603922294851 CURSOR FOR SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:32:31 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:32:31 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12572741603922294851
2026/04/21 19:32:31 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12572741603922294851 records=1 bytes=16 channelLen=0
2026/04/21 19:32:31 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=16 channelLen=0
2026/04/21 19:32:31 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12572741603922294851
2026/04/21 19:32:31 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_12572741603922294851 records=0 bytes=0 channelLen=0
2026/04/21 19:32:31 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:31 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:31 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=16 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:42 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_569384855257632985 CURSOR FOR SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" args=[]
2026/04/21 19:32:42 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_8xdfjqjl.\"table1\" ORDER BY id" channelLen=0
2026/04/21 19:32:42 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_569384855257632985
2026/04/21 19:32:42 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_569384855257632985 records=2 bytes=19 channelLen=1
2026/04/21 19:32:42 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/04/21 19:32:42 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_569384855257632985
2026/04/21 19:32:42 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_569384855257632985 records=0 bytes=0 channelLen=0
2026/04/21 19:32:42 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:42 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:42 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_8xdfjqjl.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:44 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id"
2026/04/21 19:32:44 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id"
2026/04/21 19:32:44 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17834147906989860003 CURSOR FOR SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" args=[]
2026/04/21 19:32:44 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_8xdfjqjl.\"table1\" ORDER BY id" channelLen=0
2026/04/21 19:32:44 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17834147906989860003
2026/04/21 19:32:44 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17834147906989860003 records=2 bytes=19 channelLen=1
2026/04/21 19:32:44 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/04/21 19:32:44 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17834147906989860003
2026/04/21 19:32:44 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17834147906989860003 records=0 bytes=0 channelLen=0
2026/04/21 19:32:44 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_8xdfjqjl.\"table1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:44 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:44 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_8xdfjqjl.\"table1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:48 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_x0glkood.\"valid\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:50 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:50 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:32:50 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_5953741745422637133 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" args=[]
2026/04/21 19:32:50 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" channelLen=0
2026/04/21 19:32:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5953741745422637133
2026/04/21 19:32:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5953741745422637133 records=1 bytes=8870 channelLen=0
2026/04/21 19:32:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
2026/04/21 19:32:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5953741745422637133
2026/04/21 19:32:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5953741745422637133 records=0 bytes=0 channelLen=0
2026/04/21 19:32:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:50 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=1 bytes=8870 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:52 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:32:52 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:32:52 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:32:52 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_212867790254343201 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" args=[]
2026/04/21 19:32:52 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" channelLen=0
2026/04/21 19:32:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_212867790254343201
2026/04/21 19:32:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_212867790254343201 records=1 bytes=8878 channelLen=0
2026/04/21 19:32:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=1 bytes=8878 channelLen=0
2026/04/21 19:32:52 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_212867790254343201
2026/04/21 19:32:52 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_212867790254343201 records=0 bytes=0 channelLen=0
2026/04/21 19:32:52 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:52 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:52 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=1 bytes=8878 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:32:58 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:32:58 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:32:58 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7984338620554971313 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" args=[]
2026/04/21 19:32:58 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" channelLen=0
2026/04/21 19:32:58 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7984338620554971313
2026/04/21 19:32:58 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7984338620554971313 records=1 bytes=9878 channelLen=0
2026/04/21 19:32:58 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=9878 channelLen=0
2026/04/21 19:32:58 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7984338620554971313
2026/04/21 19:32:58 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7984338620554971313 records=0 bytes=0 channelLen=0
2026/04/21 19:32:58 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:32:58 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:32:58 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=9878 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:08 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:33:08 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id"
2026/04/21 19:33:08 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17189963142588292407 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" args=[]
2026/04/21 19:33:08 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" channelLen=0
2026/04/21 19:33:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17189963142588292407
2026/04/21 19:33:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17189963142588292407 records=1 bytes=9878 channelLen=0
2026/04/21 19:33:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=9878 channelLen=0
2026/04/21 19:33:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17189963142588292407
2026/04/21 19:33:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17189963142588292407 records=0 bytes=0 channelLen=0
2026/04/21 19:33:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:08 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:08 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_zalqrlze_20260421193211.\"test_softdel_iad\" ORDER BY id" rows=1 bytes=9878 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:11 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:11 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:11 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6144820593989835035 CURSOR FOR SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:33:11 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:33:11 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6144820593989835035
2026/04/21 19:33:11 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6144820593989835035 records=3 bytes=56 channelLen=2
2026/04/21 19:33:11 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=2
2026/04/21 19:33:11 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6144820593989835035
2026/04/21 19:33:11 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6144820593989835035 records=0 bytes=0 channelLen=0
2026/04/21 19:33:11 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:11 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:11 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0w7il3ml.\"t1\" ORDER BY id"
2026/04/21 19:33:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0w7il3ml.\"t1\" ORDER BY id"
2026/04/21 19:33:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7681370557124264021 CURSOR FOR SELECT id,val FROM e2e_test_api_0w7il3ml.\"t1\" ORDER BY id" args=[]
2026/04/21 19:33:13 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_0w7il3ml.\"t1\" ORDER BY id" channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7681370557124264021
2026/04/21 19:33:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7681370557124264021 records=2 bytes=19 channelLen=1
2026/04/21 19:33:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0w7il3ml.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/04/21 19:33:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7681370557124264021
2026/04/21 19:33:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7681370557124264021 records=0 bytes=0 channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_0w7il3ml.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:13 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_0w7il3ml.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/04/21 19:33:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17778106865360003996 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" args=[]
2026/04/21 19:33:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17778106865360003996
2026/04/21 19:33:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17778106865360003996 records=0 bytes=0 channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:13 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:15 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:18 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:18 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:18 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_5985216903616934309 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" args=[]
2026/04/21 19:33:18 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" channelLen=0
2026/04/21 19:33:18 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5985216903616934309
2026/04/21 19:33:18 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5985216903616934309 records=0 bytes=0 channelLen=0
2026/04/21 19:33:18 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:18 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:18 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:22 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:22 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:22 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_15034994444240833688 CURSOR FOR SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:33:22 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:33:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15034994444240833688
2026/04/21 19:33:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15034994444240833688 records=3 bytes=56 channelLen=2
2026/04/21 19:33:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=2
2026/04/21 19:33:22 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15034994444240833688
2026/04/21 19:33:22 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15034994444240833688 records=0 bytes=0 channelLen=0
2026/04/21 19:33:22 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:22 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:22 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:33 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:33 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:33 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_1808754670164228388 CURSOR FOR SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:33:33 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:33:33 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1808754670164228388
2026/04/21 19:33:33 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1808754670164228388 records=3 bytes=56 channelLen=2
2026/04/21 19:33:33 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=2
2026/04/21 19:33:33 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1808754670164228388
2026/04/21 19:33:33 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1808754670164228388 records=0 bytes=0 channelLen=0
2026/04/21 19:33:33 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:33 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:33 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:36 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:36 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id"
2026/04/21 19:33:36 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7850421421646170120 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" args=[]
2026/04/21 19:33:36 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" channelLen=0
2026/04/21 19:33:36 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7850421421646170120
2026/04/21 19:33:36 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7850421421646170120 records=0 bytes=0 channelLen=0
2026/04/21 19:33:36 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:36 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:36 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_43r0nizo_20260421193225.\"test_softdel_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:37 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:37 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:37 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7119647751137206262 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" args=[]
2026/04/21 19:33:37 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" channelLen=0
2026/04/21 19:33:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7119647751137206262
2026/04/21 19:33:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7119647751137206262 records=2 bytes=76 channelLen=1
2026/04/21 19:33:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=1
2026/04/21 19:33:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7119647751137206262
2026/04/21 19:33:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7119647751137206262 records=0 bytes=0 channelLen=0
2026/04/21 19:33:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:37 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:37 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:40 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:40 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:40 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_2587555665731094601 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" args=[]
2026/04/21 19:33:40 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" channelLen=0
2026/04/21 19:33:40 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2587555665731094601
2026/04/21 19:33:40 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2587555665731094601 records=2 bytes=76 channelLen=1
2026/04/21 19:33:40 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=1
2026/04/21 19:33:40 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2587555665731094601
2026/04/21 19:33:40 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2587555665731094601 records=0 bytes=0 channelLen=0
2026/04/21 19:33:40 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:40 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:40 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:43 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:33:43 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id"
2026/04/21 19:33:43 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16775953037479152723 CURSOR FOR SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" args=[]
2026/04/21 19:33:43 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" channelLen=0
2026/04/21 19:33:43 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16775953037479152723
2026/04/21 19:33:43 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16775953037479152723 records=0 bytes=0 channelLen=0
2026/04/21 19:33:43 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:43 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:43 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2,t FROM e2e_test_bq_i6zdwz6n_20260421193149.\"test_softdel_ud_src\" ORDER BY id" rows=0 bytes=0 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:46 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_qoerun6o.\"myMixedCaseTable\" ORDER BY id"
2026/04/21 19:33:46 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_qoerun6o.\"myMixedCaseTable\" ORDER BY id"
2026/04/21 19:33:46 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3603730012705918469 CURSOR FOR SELECT id,\"key\" FROM e2e_test_pgch_qoerun6o.\"myMixedCaseTable\" ORDER BY id" args=[]
2026/04/21 19:33:46 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_qoerun6o.\"myMixedCaseTable\" ORDER BY id" channelLen=0
2026/04/21 19:33:46 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3603730012705918469
2026/04/21 19:33:46 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3603730012705918469 records=2 bytes=15 channelLen=1
2026/04/21 19:33:46 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_qoerun6o.\"myMixedCaseTable\" ORDER BY id" rows=2 bytes=15 channelLen=1
2026/04/21 19:33:46 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3603730012705918469
2026/04/21 19:33:46 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3603730012705918469 records=0 bytes=0 channelLen=0
2026/04/21 19:33:46 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,\"key\" FROM e2e_test_pgch_qoerun6o.\"myMixedCaseTable\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:46 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:46 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_qoerun6o.\"myMixedCaseTable\" ORDER BY id" rows=2 bytes=15 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:48 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:48 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id"
2026/04/21 19:33:48 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16872103568938886451 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" args=[]
2026/04/21 19:33:48 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" channelLen=0
2026/04/21 19:33:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16872103568938886451
2026/04/21 19:33:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16872103568938886451 records=2 bytes=76 channelLen=1
2026/04/21 19:33:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=1
2026/04/21 19:33:48 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16872103568938886451
2026/04/21 19:33:48 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16872103568938886451 records=0 bytes=0 channelLen=0
2026/04/21 19:33:48 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:48 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:48 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgch_2momp2ac.\"test_pgvector_text\" ORDER BY id" rows=2 bytes=76 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:50 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:50 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id"
2026/04/21 19:33:50 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9675282418703165617 CURSOR FOR SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/21 19:33:50 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/21 19:33:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9675282418703165617
2026/04/21 19:33:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9675282418703165617 records=3 bytes=56 channelLen=2
2026/04/21 19:33:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=2
2026/04/21 19:33:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9675282418703165617
2026/04/21 19:33:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9675282418703165617 records=0 bytes=0 channelLen=0
2026/04/21 19:33:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:50 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c3 FROM e2e_test_bq_gtkcgpz9_20260421193212.\"test_simple_schema_changes\" ORDER BY id" rows=3 bytes=56 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:420: bad json: empty result set from test_types_bq
2026/04/21 19:33:54 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_4yxhwvxf.\"t1\" ORDER BY id"
2026/04/21 19:33:54 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_4yxhwvxf.\"t1\" ORDER BY id"
2026/04/21 19:33:54 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17213652739668860515 CURSOR FOR SELECT id,val FROM e2e_test_api_4yxhwvxf.\"t1\" ORDER BY id" args=[]
2026/04/21 19:33:54 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_4yxhwvxf.\"t1\" ORDER BY id" channelLen=0
2026/04/21 19:33:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17213652739668860515
2026/04/21 19:33:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17213652739668860515 records=2 bytes=19 channelLen=1
2026/04/21 19:33:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_4yxhwvxf.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/04/21 19:33:54 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17213652739668860515
2026/04/21 19:33:54 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17213652739668860515 records=0 bytes=0 channelLen=0
2026/04/21 19:33:54 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_4yxhwvxf.\"t1\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/21 19:33:54 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/21 19:33:54 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_4yxhwvxf.\"t1\" ORDER BY id" rows=2 bytes=19 channelLen=0
    bigquery_test.go:420: bad json: empty result set from test_types_bq
    bigquery_test.go:405: UNEXPECTED TIMEOUT normalize types 2026-04-21 19:33:56.343015037 +0000 UTC m=+601.703579410
    bigquery.go:86: begin tearing down postgres schema bq_whpskpoc_20260421193150
--- FAIL: TestPeerFlowE2ETestSuiteBQ/Test_Types (141.71s)
View the full list of 1 ❄️ flaky test(s) 
github.com/PeerDB-io/peerdb/flow/e2e::TestMongoClickhouseSuite/Test_Snapshot_Empty_Collection

Flake rate in main: 41.70% (Passed 158 times, Failed 113 times)

Stack Traces | 5.05s run time 
=== RUN   TestMongoClickhouseSuite/Test_Snapshot_Empty_Collection
=== PAUSE TestMongoClickhouseSuite/Test_Snapshot_Empty_Collection
=== CONT  TestMongoClickhouseSuite/Test_Snapshot_Empty_Collection
2026/04/21 19:05:52 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/21 19:05:52 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    mongo_test.go:226: Failed to connect temporal client: failed reaching server: context deadline exceeded
--- FAIL: TestMongoClickhouseSuite/Test_Snapshot_Empty_Collection (5.05s)

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

github-actions Bot commented Apr 21, 2026

Copy link
Copy Markdown
Contributor

🔄 Flaky Test Detected

Analysis: Both failures (Test_Binary_Format_Hex and TestCancelTableAdditionRemoveAddRemove) show FATAL: terminating connection due to administrator command (SQLSTATE 57P01), a PostgreSQL race condition where one test's teardown kills the catalog connection of a concurrently running test in the -p 32 parallel test suite.
Confidence: 0.95

✅ Automatically retrying the workflow

View workflow run

@pfcoperez pfcoperez mentioned this pull request Apr 21, 2026
Merged
1 task
ilidemi
ilidemi approved these changes Apr 21, 2026
View reviewed changes
Comment thread .github/workflows/flow.yml Outdated
@pfcoperez @ilidemi
PR Comments: Include ClickHouse version in the compatibility matrix i…
b43b2d7 
…d field

Co-authored-by: Ilia Demianenko <ilia.demianenko@clickhouse.com>
@github-actions

github-actions Bot commented Apr 21, 2026

Copy link
Copy Markdown
Contributor

🔄 Flaky Test Detected

Analysis: All three failures across different matrix jobs are infrastructure/timing issues (Temporal context deadline exceeded, PostgreSQL catalog connection terminated by admin command, async initial-load wait timeout), not deterministic test logic failures.
Confidence: 0.92

✅ Automatically retrying the workflow

View workflow run

@github-actions

github-actions Bot commented Apr 21, 2026

Copy link
Copy Markdown
Contributor

🔄 Flaky Test Detected

Analysis: Both failures are infrastructure/timing flakiness: one test lost its catalog DB connection mid-run (Postgres SQLSTATE 57P01 admin_shutdown), and another hit a snapshot status timeout — neither indicates a code regression.
Confidence: 0.95

✅ Automatically retrying the workflow

View workflow run

@github-actions

github-actions Bot commented Apr 21, 2026

Copy link
Copy Markdown
Contributor

🔄 Flaky Test Detected

Analysis: Both failures are transient infrastructure issues: one test failed with "context deadline exceeded" connecting to Temporal server, and the other timed out under heavy CI load (32 parallel e2e tests near the 900s limit).
Confidence: 0.92

✅ Automatically retrying the workflow

View workflow run

@pfcoperez pfcoperez merged commit 113f9a1 into main Apr 21, 2026
15 of 22 checks passed
@pfcoperez pfcoperez deleted the DBI-671/test/o11y/add-matrix-configuration-id branch April 21, 2026 20:41
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@ilidemi ilidemi ilidemi approved these changes
@jgao54 jgao54 Awaiting requested review from jgao54
@masterashu masterashu Awaiting requested review from masterashu

Assignees

@pfcoperez pfcoperez

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

2 participants

@pfcoperez @ilidemi