Skip to content

Drop sqlparser-rs (0.45) fork in favor of upstream (0.61)#4145

Open
serprex wants to merge 1 commit intomainfrom
upstream-sqlparser
Open

Drop sqlparser-rs (0.45) fork in favor of upstream (0.61)#4145
serprex wants to merge 1 commit intomainfrom
upstream-sqlparser

Conversation

@serprex
Copy link
Copy Markdown
Member

@serprex serprex commented Apr 6, 2026

in-tree parser intercepts PeerDB DDL,
old parser crate renamed to query-router

@serprex serprex requested a review from heavycrystal April 6, 2026 02:34
@serprex serprex force-pushed the upstream-sqlparser branch 3 times, most recently from 7e2ff61 to 6839710 Compare April 6, 2026 02:47
@codecov
Copy link
Copy Markdown

codecov bot commented Apr 6, 2026 •
edited
Loading

❌ 46 Tests Failed:

Tests completed Failed Passed Skipped
2214 46 2168 188
View the top 3 failed test(s) by shortest run time 
github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg
Stack Traces | 0s run time 
=== RUN   TestApiPg
=== PAUSE TestApiPg
=== CONT  TestApiPg
--- FAIL: TestApiPg (0.00s)
2026/04/06 03:26:36 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:26:36 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:26:36 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:26:36 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:26:36 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_5878790734438963042 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:26:36 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:26:36 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5878790734438963042
2026/04/06 03:26:36 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5878790734438963042 records=2 bytes=12 channelLen=1
2026/04/06 03:26:36 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=1
2026/04/06 03:26:36 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5878790734438963042
2026/04/06 03:26:36 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_5878790734438963042 records=0 bytes=0 channelLen=0
2026/04/06 03:26:36 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:26:36 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:26:36 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pgchg_3hkymzxu.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0

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

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF
Stack Traces | 0s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF
=== PAUSE TestPeerFlowE2ETestSuiteSF
=== CONT  TestPeerFlowE2ETestSuiteSF
--- FAIL: TestPeerFlowE2ETestSuiteSF (0.00s)
2026/04/06 03:22:19 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:22:19 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:22:19 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:19 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:19 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_1366065858932775526 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:19 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:19 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1366065858932775526
2026/04/06 03:22:19 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1366065858932775526 records=2 bytes=12 channelLen=1
2026/04/06 03:22:19 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:19 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1366065858932775526
2026/04/06 03:22:19 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1366065858932775526 records=0 bytes=0 channelLen=0
2026/04/06 03:22:19 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:19 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:19 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:19 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:19 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:19 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6508823575477577662 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:19 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"

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

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting
Stack Traces | 0.52s run time 
=== RUN   TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting
=== PAUSE TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting
=== CONT  TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting (0.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple
Stack Traces | 0.52s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple (0.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch
Stack Traces | 0.52s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch
2026/04/06 03:22:14 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:14 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:14 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_15135714463582745785 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:14 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:14 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:14 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:14 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15135714463582745785
2026/04/06 03:22:14 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14997849059507309739 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ptzfad5e.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:22:14 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:22:14 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15135714463582745785 records=2 bytes=12 channelLen=1
2026/04/06 03:22:14 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=1
2026/04/06 03:22:14 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15135714463582745785
2026/04/06 03:22:14 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_15135714463582745785 records=0 bytes=0 channelLen=0
2026/04/06 03:22:14 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:14 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:14 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:14 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:14 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:14 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14997849059507309739
2026/04/06 03:22:14 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_5504316706500389942 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:14 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch (0.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
Stack Traces | 0.52s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
2026/04/06 03:22:12 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:12 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:12 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16819763651376760405 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:12 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:12 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:12 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:12 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6647591023193107211 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ptzfad5e.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:22:12 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:22:12 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16819763651376760405
2026/04/06 03:22:12 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16819763651376760405 records=2 bytes=12 channelLen=1
2026/04/06 03:22:12 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:12 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16819763651376760405
2026/04/06 03:22:12 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16819763651376760405 records=0 bytes=0 channelLen=0
2026/04/06 03:22:12 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:12 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:12 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:12 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:12 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:12 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6647591023193107211
2026/04/06 03:22:12 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3523176204627151386 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:12 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6647591023193107211 records=13 bytes=293 channelLen=12
2026/04/06 03:22:12 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/06 03:22:12 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6647591023193107211
2026/04/06 03:22:12 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:12 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6647591023193107211 records=0 bytes=0 channelLen=0
2026/04/06 03:22:12 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:12 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF (0.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration
Stack Traces | 0.53s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration (0.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF
Stack Traces | 0.53s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF (0.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF
Stack Traces | 0.53s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF (0.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Partitioned_Table_Without_Publish_Via_Partition_Root
Stack Traces | 0.54s run time 
=== RUN   TestGenericSF/Test_Partitioned_Table_Without_Publish_Via_Partition_Root
=== PAUSE TestGenericSF/Test_Partitioned_Table_Without_Publish_Via_Partition_Root
=== CONT  TestGenericSF/Test_Partitioned_Table_Without_Publish_Via_Partition_Root
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Partitioned_Table_Without_Publish_Via_Partition_Root (0.54s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN
Stack Traces | 0.55s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN (0.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF
Stack Traces | 0.55s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF (0.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey
Stack Traces | 0.55s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey (0.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF
Stack Traces | 0.55s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF (0.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch
Stack Traces | 0.55s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch (0.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Schema_Changes_Cutoff_Bug
Stack Traces | 0.57s run time 
=== RUN   TestGenericSF/Test_Schema_Changes_Cutoff_Bug
=== PAUSE TestGenericSF/Test_Schema_Changes_Cutoff_Bug
=== CONT  TestGenericSF/Test_Schema_Changes_Cutoff_Bug
2026/04/06 03:27:59 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:27:59 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:27:59 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8314935253441506925 CURSOR FOR SELECT id,name,created_at FROM e2e_test_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:27:59 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:27:59 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8314935253441506925
2026/04/06 03:27:59 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8314935253441506925 records=13 bytes=293 channelLen=12
2026/04/06 03:27:59 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/06 03:27:59 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8314935253441506925
2026/04/06 03:27:59 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8314935253441506925 records=0 bytes=0 channelLen=0
2026/04/06 03:27:59 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:27:59 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:27:59 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=0
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Schema_Changes_Cutoff_Bug (0.57s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Types_SF
Stack Traces | 0.57s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Types_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Types_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Types_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Types_SF (0.57s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
Stack Traces | 0.57s run time 
=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
2026/04/06 03:25:09 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'"
2026/04/06 03:25:09 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'"
2026/04/06 03:25:09 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_1785516072886076234 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" args=[]
2026/04/06 03:25:09 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" channelLen=0
2026/04/06 03:25:09 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1785516072886076234
2026/04/06 03:25:09 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1785516072886076234 records=1 bytes=8 channelLen=0
2026/04/06 03:25:09 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:25:09 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1785516072886076234
2026/04/06 03:25:09 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_1785516072886076234 records=0 bytes=0 channelLen=0
2026/04/06 03:25:09 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=0 bytes=0 channelLen=0
2026/04/06 03:25:09 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:25:09 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=1 bytes=8 channelLen=0
    e2eshared.go:34: Error in test: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames (0.57s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Simple_Flow
Stack Traces | 0.58s run time 
=== RUN   TestGenericSF/Test_Simple_Flow
=== PAUSE TestGenericSF/Test_Simple_Flow
=== CONT  TestGenericSF/Test_Simple_Flow
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Simple_Flow (0.58s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns
Stack Traces | 0.61s run time 
=== RUN   TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns
=== PAUSE TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns
=== CONT  TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Schema_Change_Lost_Column_Bug
Stack Traces | 0.61s run time 
=== RUN   TestGenericSF/Test_Schema_Change_Lost_Column_Bug
=== PAUSE TestGenericSF/Test_Schema_Change_Lost_Column_Bug
=== CONT  TestGenericSF/Test_Schema_Change_Lost_Column_Bug
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Schema_Change_Lost_Column_Bug (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Simple_Schema_Changes
Stack Traces | 0.61s run time 
=== RUN   TestGenericSF/Test_Simple_Schema_Changes
=== PAUSE TestGenericSF/Test_Simple_Schema_Changes
=== CONT  TestGenericSF/Test_Simple_Schema_Changes
2026/04/06 03:27:58 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9442388767263590906
2026/04/06 03:27:58 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9442388767263590906 records=1 bytes=21 channelLen=0
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance\" ORDER BY id" rows=1 bytes=21 channelLen=0
2026/04/06 03:27:58 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9442388767263590906
2026/04/06 03:27:58 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9442388767263590906 records=0 bytes=0 channelLen=0
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:27:58 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance\" ORDER BY id" rows=1 bytes=21 channelLen=0
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id"
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id"
2026/04/06 03:27:58 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10428834395663891851 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id" args=[]
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id" channelLen=0
2026/04/06 03:27:58 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10428834395663891851
2026/04/06 03:27:58 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10428834395663891851 records=0 bytes=0 channelLen=0
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:27:58 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:27:58 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_ozvmn2rb.\"test_inheritance_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Simple_Schema_Changes (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF
Stack Traces | 0.61s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames
Stack Traces | 0.61s run time 
=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames
    e2eshared.go:34: Error in test: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion
Stack Traces | 0.62s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion (0.62s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes
Stack Traces | 0.63s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes
2026/04/06 03:22:17 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychclg_yuatfh7q.test_lost_column_bug
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes (0.63s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_2_SF
Stack Traces | 0.65s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_2_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_2_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_2_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_2_SF (0.65s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3
Stack Traces | 0.66s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3 (0.66s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric
Stack Traces | 0.67s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric (0.67s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic
Stack Traces | 0.68s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic (0.68s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF
Stack Traces | 0.68s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF
2026/04/06 03:22:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id"
2026/04/06 03:22:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id"
2026/04/06 03:22:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16038278508729042542 CURSOR FOR SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id" args=[]
2026/04/06 03:22:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id" channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16038278508729042542
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16038278508729042542 records=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16038278508729042542
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16038278508729042542 records=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:13 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_pg_7muw2vr8.\"test_simple_schema_changes\" ORDER BY id" rows=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id"
2026/04/06 03:22:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id"
2026/04/06 03:22:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13291279747242330663 CURSOR FOR SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id" args=[]
2026/04/06 03:22:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id" channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13291279747242330663
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13291279747242330663 records=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id" rows=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13291279747242330663
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13291279747242330663 records=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1 FROM e2e_test_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:13 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_pg_7muw2vr8.\"test_simple_schema_changes_dst\" ORDER BY id" rows=1 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_pg_7muw2vr8.test_simple_schema_changes_dst
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF (0.68s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete
Stack Traces | 0.69s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete (0.69s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Partitioned_Table
Stack Traces | 0.7s run time 
=== RUN   TestGenericSF/Test_Partitioned_Table
=== PAUSE TestGenericSF/Test_Partitioned_Table
=== CONT  TestGenericSF/Test_Partitioned_Table
2026/04/06 03:28:00 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,name,created_at FROM e2e_test_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:28:00 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:28:00 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_3646263895324581839 CURSOR FOR SELECT id,name,created_at FROM e2e_test_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:28:00 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:28:00 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3646263895324581839
2026/04/06 03:28:00 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3646263895324581839 records=13 bytes=293 channelLen=12
2026/04/06 03:28:00 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/06 03:28:00 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3646263895324581839
2026/04/06 03:28:00 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_3646263895324581839 records=0 bytes=0 channelLen=0
2026/04/06 03:28:00 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:28:00 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:28:00 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_bq_dycu6gza_20260406032718.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=0
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Partitioned_Table (0.70s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
Stack Traces | 0.72s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Toast_SF (0.72s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
Stack Traces | 0.73s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
2026/04/06 03:22:16 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:16 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:16 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10455501238535550163 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:16 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:16 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10455501238535550163
2026/04/06 03:22:16 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10455501238535550163 records=2 bytes=12 channelLen=1
2026/04/06 03:22:16 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:16 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10455501238535550163
2026/04/06 03:22:16 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_10455501238535550163 records=0 bytes=0 channelLen=0
2026/04/06 03:22:16 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:16 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:16 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:16 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:16 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:16 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:16 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:16 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4741085974738333689 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:16 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6319378335923748692 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ptzfad5e.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:22:16 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:22:16 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF (0.73s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
Stack Traces | 0.76s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
2026/04/06 03:22:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14337941686564820102 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:13 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:13 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:13 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:13 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_18077214441795745227 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ptzfad5e.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:22:13 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14337941686564820102
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14337941686564820102 records=2 bytes=12 channelLen=1
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=1
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14337941686564820102
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14337941686564820102 records=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:13 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:13 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:13 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:13 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_18077214441795745227
2026/04/06 03:22:13 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8526451413460701587 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:13 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_18077214441795745227 records=13 bytes=293 channelLen=12
2026/04/06 03:22:13 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/06 03:22:13 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_18077214441795745227
2026/04/06 03:22:13 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF (0.76s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting
Stack Traces | 0.78s run time 
=== RUN   TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting
=== PAUSE TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting
=== CONT  TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting (0.78s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only
Stack Traces | 0.79s run time 
=== RUN   TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only
=== PAUSE TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only
=== CONT  TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:27:31 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4291527098777816229 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pgchclg_uzbnmhwi.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:27:31 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4291527098777816229
2026/04/06 03:27:31 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4291527098777816229 records=13 bytes=293 channelLen=12
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=12
2026/04/06 03:27:31 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4291527098777816229
2026/04/06 03:27:31 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4291527098777816229 records=0 bytes=0 channelLen=0
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:27:31 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:27:31 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_uzbnmhwi.\"test_partition_noroot\" ORDER BY id" rows=13 bytes=293 channelLen=0
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only (0.79s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Initial_Custom_Partition
Stack Traces | 0.8s run time 
=== RUN   TestGenericSF/Test_Initial_Custom_Partition
=== PAUSE TestGenericSF/Test_Initial_Custom_Partition
=== CONT  TestGenericSF/Test_Initial_Custom_Partition
2026/04/06 03:28:01 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id"
2026/04/06 03:28:01 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id"
2026/04/06 03:28:01 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8110826535534557638 CURSOR FOR SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id" args=[]
2026/04/06 03:28:01 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id" channelLen=0
2026/04/06 03:28:01 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8110826535534557638
2026/04/06 03:28:01 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8110826535534557638 records=2 bytes=23 channelLen=1
2026/04/06 03:28:01 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id" rows=2 bytes=23 channelLen=1
2026/04/06 03:28:01 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8110826535534557638
2026/04/06 03:28:01 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8110826535534557638 records=0 bytes=0 channelLen=0
2026/04/06 03:28:01 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:28:01 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:28:01 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,good_column,lost_column FROM e2e_test_bq_wnldesat_20260406032716.\"test_lost_column_bug\" ORDER BY id" rows=2 bytes=23 channelLen=0
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestGenericSF/Test_Initial_Custom_Partition (0.80s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
Stack Traces | 0.81s run time 
=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
    e2eshared.go:34: Error in test: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn (0.81s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC
Stack Traces | 0.86s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC
2026/04/06 03:22:15 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:15 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:15 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17620708643113554628 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:15 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:15 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17620708643113554628
2026/04/06 03:22:15 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:15 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:15 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17620708643113554628 records=2 bytes=12 channelLen=1
2026/04/06 03:22:15 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:15 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17620708643113554628
2026/04/06 03:22:15 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17620708643113554628 records=0 bytes=0 channelLen=0
2026/04/06 03:22:15 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:15 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:15 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_10979281961022698268 CURSOR FOR SELECT id,name,created_at FROM e2e_test_pg_ptzfad5e.\"test_partition_noroot\" ORDER BY id" args=[]
2026/04/06 03:22:15 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id" channelLen=0
2026/04/06 03:22:15 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:15 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:15 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:15 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_12335146156866538898 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:15 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC (0.86s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF
Stack Traces | 0.89s run time 
=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF
2026/04/06 03:22:17 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:17 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id"
2026/04/06 03:22:17 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8155995142822790081 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" args=[]
2026/04/06 03:22:17 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" channelLen=0
2026/04/06 03:22:17 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8155995142822790081
2026/04/06 03:22:17 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8155995142822790081 records=2 bytes=12 channelLen=1
2026/04/06 03:22:17 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:17 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8155995142822790081
2026/04/06 03:22:17 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8155995142822790081 records=0 bytes=0 channelLen=0
2026/04/06 03:22:17 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:22:17 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:22:17 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column\" ORDER BY id" rows=2 bytes=12 channelLen=0
2026/04/06 03:22:17 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:17 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id"
2026/04/06 03:22:17 INFO [pg_query_executor] failed to declare cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_5540507428445194750 CURSOR FOR SELECT id, col_to_add FROM e2e_test_pg_fpg7e3jo.\"test_ddl_drop_column_dst\" ORDER BY id" args=[] error="ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:17 ERROR [pg_query_executor] failed to execute and process query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart error="[pg_query_executor] failed to declare cursor: ERROR: column \"col_to_add\" does not exist (SQLSTATE 42703)"
2026/04/06 03:22:17 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
2026/04/06 03:22:17 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_ptzfad5e.\"test_partition_noroot\" ORDER BY id"
    e2eshared.go:34: failed to setup Snowflake: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF (0.89s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
Stack Traces | 0.94s run time 
=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
2026/04/06 03:25:08 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'"
2026/04/06 03:25:08 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'"
2026/04/06 03:25:08 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_9089770275878976687 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" args=[]
2026/04/06 03:25:08 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" channelLen=0
2026/04/06 03:25:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9089770275878976687
2026/04/06 03:25:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9089770275878976687 records=1 bytes=8 channelLen=0
2026/04/06 03:25:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:25:08 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9089770275878976687
2026/04/06 03:25:08 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_9089770275878976687 records=0 bytes=0 channelLen=0
2026/04/06 03:25:08 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=0 bytes=0 channelLen=0
2026/04/06 03:25:08 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:25:08 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('cancel_table_addition_test_flow_with_removal_api_5dij9xo0' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_5dij9xo0.t5_mv_api_5dij9xo0%'" rows=1 bytes=8 channelLen=0
    e2eshared.go:34: Error in test: failed to create Snowflake test database: 000666 (57014): Your account is suspended due to lack of payment method.
--- FAIL: TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes (0.94s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
Stack Traces | 4.17s run time 
=== RUN   TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
=== PAUSE TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
=== CONT  TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
2026/04/06 03:24:48 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:24:48 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:2620: WaitFor wait for flow to be running 2026-04-06 03:24:52.482471071 +0000 UTC m=+5.135143070
    api_test.go:2631: 
        	Error Trace:	.../flow/e2e/api_test.go:2631
        	            				.../hostedtoolcache/go/1.26.1.../src/runtime/asm_amd64.s:1771
        	Error:      	"1" is not greater than "1"
        	Test:       	TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
        	Messages:   	Should have multiple executions (continue-as-new happened)
    api_test.go:46: begin tearing down postgres schema api_cqpp8yi0
--- FAIL: TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew (4.17s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestQRep
Stack Traces | 63.4s run time 
=== RUN   TestApiPg/TestQRep
=== PAUSE TestApiPg/TestQRep
=== CONT  TestApiPg/TestQRep
2026/04/06 03:24:47 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:24:47 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 03:24:47 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:2066: WaitFor qrep initial load 2026-04-06 03:24:47.961573008 +0000 UTC m=+0.614245007
    api_test.go:2066: code: 60, message: Unknown table expression identifier 'qrepapi_api_zg98xl9t' in scope SELECT id, val FROM qrepapi_api_zg98xl9t FINAL WHERE _peerdb_is_deleted = 0 ORDER BY 1 ASC SETTINGS use_query_cache = false
2026/04/06 03:24:47 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:2066: q.NumRecords: 1
    api_test.go:2066: other.NumRecords: 0
2026/04/06 03:24:49 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:49 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:49 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_17239075831028519968 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" args=[]
2026/04/06 03:24:49 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" channelLen=0
2026/04/06 03:24:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17239075831028519968
2026/04/06 03:24:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17239075831028519968 records=1 bytes=8 channelLen=0
2026/04/06 03:24:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:24:49 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17239075831028519968
2026/04/06 03:24:49 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_17239075831028519968 records=0 bytes=0 channelLen=0
2026/04/06 03:24:49 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:49 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:49 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:24:49 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:49 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:49 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_829948036871117388 CURSOR FOR SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" args=[]
2026/04/06 03:24:49 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_829948036871117388
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_829948036871117388 records=1 bytes=9 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=1 bytes=9 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_829948036871117388
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_829948036871117388 records=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:50 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=1 bytes=9 channelLen=0
    api_test.go:2071: WaitFor insert post qrep initial load 2026-04-06 03:24:50.007906632 +0000 UTC m=+2.660578629
2026/04/06 03:24:50 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:50 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:50 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_6175407133218137017 CURSOR FOR SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" args=[]
2026/04/06 03:24:50 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6175407133218137017
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6175407133218137017 records=2 bytes=19 channelLen=1
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=2 bytes=19 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6175407133218137017
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_6175407133218137017 records=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:50 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=2 bytes=19 channelLen=0
    api_test.go:2071: q.NumRecords: 2
    api_test.go:2071: other.NumRecords: 1
2026/04/06 03:24:50 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:50 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:50 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_2085222656961978436 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" args=[]
2026/04/06 03:24:50 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2085222656961978436
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2085222656961978436 records=1 bytes=8 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2085222656961978436
2026/04/06 03:24:50 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_2085222656961978436 records=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:50 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:50 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:24:51 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:51 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id"
2026/04/06 03:24:51 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_13335521769339332198 CURSOR FOR SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" args=[]
2026/04/06 03:24:51 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13335521769339332198
2026/04/06 03:24:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13335521769339332198 records=2 bytes=19 channelLen=1
2026/04/06 03:24:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=2 bytes=19 channelLen=1
2026/04/06 03:24:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13335521769339332198
2026/04/06 03:24:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_13335521769339332198 records=0 bytes=0 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,val FROM e2e_test_api_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:51 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_zg98xl9t.\"qrepapi_api_zg98xl9t\" ORDER BY id" rows=2 bytes=19 channelLen=0
    api_test.go:2090: WaitFor finish 2026-04-06 03:24:51.036193143 +0000 UTC m=+3.688865141
2026/04/06 03:24:51 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:51 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'"
2026/04/06 03:24:51 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_16095303595640127547 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" args=[]
2026/04/06 03:24:51 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16095303595640127547
2026/04/06 03:24:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16095303595640127547 records=1 bytes=8 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16095303595640127547
2026/04/06 03:24:51 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_16095303595640127547 records=0 bytes=0 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=0 bytes=0 channelLen=0
2026/04/06 03:24:51 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 03:24:51 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="\n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('resync_failed_api_cv28mijq' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_cv28mijq.resync_failed_api_cv28mijq_mv_api_cv28mijq%'" rows=1 bytes=8 channelLen=0
    api_test.go:2090: UNEXPECTED TIMEOUT finish 2026-04-06 03:25:51.172132279 +0000 UTC m=+63.824804267
    api_test.go:46: begin tearing down postgres schema api_zg98xl9t
--- FAIL: TestApiPg/TestQRep (63.39s)

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

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake e2e tests failed deterministically because the CI Snowflake account is suspended due to a missing payment method (error 57014).
Confidence: 0.99

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

View workflow run

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

🔄 Flaky Test Detected

Analysis: The e2e test package timed out after 756s in only the mysql-pos/MySQL-7.0 matrix variant with no assertion failures logged, consistent with a known-flaky e2e timeout rather than a deterministic code bug.
Confidence: 0.75

✅ Automatically retrying the workflow

View workflow run

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: The Snowflake CI account is suspended due to a missing payment method (error 000666/57014), causing all Snowflake tests to fail deterministically across every matrix configuration.
Confidence: 0.99

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

View workflow run

@serprex serprex force-pushed the upstream-sqlparser branch from 6839710 to 56801da Compare April 6, 2026 03:04
@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake e2e tests fail with "Your account is suspended due to lack of payment method" (Snowflake error 000666/57014) — the CI Snowflake account has been suspended, not a code or flaky test issue.
Confidence: 0.99

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

View workflow run

@serprex serprex force-pushed the upstream-sqlparser branch 2 times, most recently from 8bfe78c to 1861dc4 Compare April 6, 2026 03:15
@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake tests failed because the Snowflake CI test account is suspended due to lack of payment method (error 000666/57014), which is an infrastructure/billing issue unrelated to code changes.
Confidence: 0.98

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

View workflow run

@serprex serprex requested a review from Amogh-Bharadwaj April 6, 2026 03:16
@serprex serprex mentioned this pull request Apr 6, 2026
Open
@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake tests fail deterministically with "000666 (57014): Your account is suspended due to lack of payment method" — the CI Snowflake account has been suspended, not a flaky test.
Confidence: 0.99

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

View workflow run

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake tests fail with a deterministic billing error ("Your account is suspended due to lack of payment method"), indicating the CI Snowflake account has been suspended rather than any code regression or flaky behavior.
Confidence: 0.98

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

View workflow run

@github-actions
Copy link
Copy Markdown
Contributor

github-actions bot commented Apr 6, 2026

❌ Test Failure

Analysis: All Snowflake e2e tests fail because the Snowflake CI account is suspended due to lack of a payment method (error 000666/57014), which is an infrastructure issue unrelated to the code changes.
Confidence: 0.97

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

View workflow run

@serprex
Drop sqlparser-rs (0.45) fork in favor of upstream (0.61)
adef824 
in-tree `parser` intercepts PeerDB DDL,
old `parser` crate renamed to `query-router`
@serprex serprex force-pushed the upstream-sqlparser branch from 1861dc4 to adef824 Compare April 6, 2026 13:10
@serprex serprex requested a review from jgao54 April 9, 2026 05:44
@pfcoperez pfcoperez mentioned this pull request Apr 13, 2026
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

@heavycrystal heavycrystal Awaiting requested review from heavycrystal

@Amogh-Bharadwaj Amogh-Bharadwaj Awaiting requested review from Amogh-Bharadwaj

@jgao54 jgao54 Awaiting requested review from jgao54

At least 1 approving review is required to merge this pull request.

Assignees

No one assigned

Labels

None yet

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@serprex