PG to PG: Add destination validation check for empty table by Amogh-Bharadwaj · Pull Request #4139 · PeerDB-io/peerdb

Amogh-Bharadwaj · 2026-04-03T12:01:17Z

Similar to how we do for ClickHouse, this PR adds a validation check for PG destination mirrors for initial load mirrors where the target table has rows (we block here). If CDC-only then this check is bypassed.

github-actions · 2026-04-03T12:20:46Z

❌ Test Failure

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

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

View workflow run

codecov · 2026-04-05T12:05:31Z

❌ 43 Tests Failed:

Tests completed	Failed	Passed	Skipped
2216	43	2173	192

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)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF

Stack Traces | 0s run time

=== RUN   TestGenericSF
=== PAUSE TestGenericSF
=== CONT  TestGenericSF
--- FAIL: TestGenericSF (0.00s)
2026/04/06 17:19:41 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 17:19:41 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF

Stack Traces | 0s run time

=== RUN   TestPeerFlowE2ETestSuiteSF
=== PAUSE TestPeerFlowE2ETestSuiteSF
=== CONT  TestPeerFlowE2ETestSuiteSF
--- FAIL: TestPeerFlowE2ETestSuiteSF (0.00s)

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_Partitioned_Table_Without_Publish_Via_Partition_Root

Stack Traces | 0.45s 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.45s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Partitioned_Table

Stack Traces | 0.46s run time

=== RUN   TestGenericSF/Test_Partitioned_Table
=== PAUSE TestGenericSF/Test_Partitioned_Table
=== CONT  TestGenericSF/Test_Partitioned_Table
    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.46s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Inheritance_Table_With_Dynamic_Setting

Stack Traces | 0.47s 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.47s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Inheritance_Table_Without_Dynamic_Setting

Stack Traces | 0.5s 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.50s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF

Stack Traces | 0.5s 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
    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.50s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_Simple

Stack Traces | 0.5s 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.50s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Supported_Mixed_Case_Table_SF

Stack Traces | 0.5s 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
    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.50s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Flow_ReplicaIdentity_Index_No_Pkey

Stack Traces | 0.51s 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.51s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Schema_Change_Lost_Column_Bug

Stack Traces | 0.52s 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.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Multi_Table_SF

Stack Traces | 0.52s 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.52s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Simple_Schema_Changes

Stack Traces | 0.53s run time

=== RUN   TestGenericSF/Test_Simple_Schema_Changes
=== PAUSE TestGenericSF/Test_Simple_Schema_Changes
=== CONT  TestGenericSF/Test_Simple_Schema_Changes
2026/04/06 17:19:38 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id"
2026/04/06 17:19:38 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id"
2026/04/06 17:19:38 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_4763438637633035926 CURSOR FOR SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" args=[]
2026/04/06 17:19:38 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" channelLen=0
2026/04/06 17:19:38 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4763438637633035926
2026/04/06 17:19:38 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4763438637633035926 records=4 bytes=80 channelLen=3
2026/04/06 17:19:38 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 channelLen=3
2026/04/06 17:19:38 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4763438637633035926
2026/04/06 17:19:38 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_4763438637633035926 records=0 bytes=0 channelLen=0
2026/04/06 17:19:38 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 17:19:38 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 17:19:38 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 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.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_Upsert_XMIN

Stack Traces | 0.53s 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.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Insert_After_Delete

Stack Traces | 0.53s 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.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Initial_Custom_Partition

Stack Traces | 0.54s run time

=== RUN   TestGenericSF/Test_Initial_Custom_Partition
=== PAUSE TestGenericSF/Test_Initial_Custom_Partition
=== CONT  TestGenericSF/Test_Initial_Custom_Partition
    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.54s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames

Stack Traces | 0.54s run time

=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestAddTrickyColumnNames
    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.54s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3_Integration

Stack Traces | 0.55s 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.55s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_PeerDB_Columns_QRep_SF

Stack Traces | 0.56s 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.56s)

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
    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_Toast_Advance_2_SF

Stack Traces | 0.57s 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.57s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Complete_QRep_Flow_Avro_SF_S3

Stack Traces | 0.61s 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
2026/04/06 17:10:28 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychg_vq3gn83a.test_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_S3 (0.61s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_2_SF

Stack Traces | 0.63s 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.63s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddWhitespaceColumnNames

Stack Traces | 0.63s 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.63s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn

Stack Traces | 0.66s run time

=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestSimpleAddColumn
2026/04/06 17:12:31 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 17:12:31 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    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.66s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF

Stack Traces | 0.67s run time

=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_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_SF (0.67s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF

Stack Traces | 0.69s run time

=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_1_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_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_Toast_Advance_1_SF (0.69s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Simple_Flow

Stack Traces | 0.7s 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.70s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Composite_PKey_Toast_1_SF

Stack Traces | 0.7s 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
2026/04/06 17:10:27 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychg_vq3gn83a.test_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_Composite_PKey_Toast_1_SF (0.70s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Default_False_SF

Stack Traces | 0.7s 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.70s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion_With_Schema_Changes

Stack Traces | 0.71s 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
    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.71s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Invalid_Geo_SF_Avro_CDC

Stack Traces | 0.71s 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
    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.71s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Types_SF

Stack Traces | 0.73s 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.73s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Invalid_Numeric

Stack Traces | 0.75s 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.75s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_Basic

Stack Traces | 0.75s 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.75s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_IUD_Same_Batch

Stack Traces | 0.76s 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
    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.76s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Schema_Change_Drop_Consecutive_Columns

Stack Traces | 0.91s 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
2026/04/06 17:19:37 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id"
2026/04/06 17:19:37 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id"
2026/04/06 17:19:37 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_7384922670109612529 CURSOR FOR SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" args=[]
2026/04/06 17:19:37 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" channelLen=0
2026/04/06 17:19:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7384922670109612529
2026/04/06 17:19:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7384922670109612529 records=4 bytes=80 channelLen=3
2026/04/06 17:19:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 channelLen=0
2026/04/06 17:19:37 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7384922670109612529
2026/04/06 17:19:37 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_7384922670109612529 records=0 bytes=0 channelLen=0
2026/04/06 17:19:37 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=0 bytes=0 channelLen=0
2026/04/06 17:19:37 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2026/04/06 17:19:37 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,t FROM e2e_test_pgchcl_d3hhkdbp.\"test_exclude_ch\" ORDER BY id" rows=4 bytes=80 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_Change_Drop_Consecutive_Columns (0.91s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF

Stack Traces | 1.1s run time

=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_Advance_3_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_3_SF (1.10s)

github.com/PeerDB-io/peerdb/flow/e2e::TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes

Stack Traces | 1.1s run time

=== RUN   TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
=== PAUSE TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
=== CONT  TestSnowflakeSchemaDeltaTestSuite/TestAddAllColumnTypes
    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 (1.10s)

github.com/PeerDB-io/peerdb/flow/e2e::TestGenericSF/Test_Custom_Replication_Slot_Starting_With_Numbers_CDC_Only

Stack Traces | 1.14s 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
    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 (1.14s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Column_Exclusion

Stack Traces | 1.31s 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 (1.31s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Toast_SF

Stack Traces | 1.53s run time

=== RUN   TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
=== PAUSE TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
=== CONT  TestPeerFlowE2ETestSuiteSF/Test_Toast_SF
2026/04/06 17:10:29 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychg_vq3gn83a.test_simple
2026/04/06 17:10:29 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychg_nf53p2tr.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_Toast_SF (1.53s)

github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteSF/Test_Soft_Delete_UD_Same_Batch

Stack Traces | 1.64s 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 (1.64s)

github.com/PeerDB-io/peerdb/flow/e2e::TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew

Stack Traces | 4.21s run time

=== RUN   TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
=== PAUSE TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
=== CONT  TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew
2026/04/06 16:51:32 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/04/06 16:51:32 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    api_test.go:2680: WaitFor wait for flow to be running 2026-04-06 16:51:36.608532779 +0000 UTC m=+5.091947257
    api_test.go:2691: 
        	Error Trace:	.../flow/e2e/api_test.go:2691
        	            				.../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_jjx1bpaf
--- FAIL: TestApiPg/TestCreateCDCFlowAttachIdempotentAfterContinueAsNew (4.21s)

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 · 2026-04-05T12:07:43Z

❌ Test Failure

Analysis: All 17 failures are caused by the Snowflake CI account being suspended due to a missing payment method (error 000666/57014), not a code regression or flaky test.
Confidence: 0.99

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

View workflow run

github-actions · 2026-04-06T17:06:20Z

🔄 Flaky Test Detected

Analysis: All Snowflake test failures are caused by the CI Snowflake account being suspended due to lack of payment method (error 000666/57014), which is an external infrastructure issue unrelated to the code change.
Confidence: 0.95

✅ Automatically retrying the workflow

View workflow run

github-actions · 2026-04-06T17:25:06Z

❌ Test Failure

Analysis: All failures are caused by the Snowflake CI account being suspended due to a missing payment method (error 000666/57014), not a code or flakiness issue.
Confidence: 0.99

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

View workflow run

Amogh-Bharadwaj requested a review from serprex April 3, 2026 12:01

serprex reviewed Apr 3, 2026

View reviewed changes

Comment thread flow/pkg/postgres/validation.go Outdated

serprex reviewed Apr 3, 2026

View reviewed changes

Comment thread flow/e2e/api_test.go Outdated

Amogh-Bharadwaj force-pushed the pg-pg/empty-table-check branch from 7f904eb to b7276f2 Compare April 5, 2026 11:49

Amogh-Bharadwaj added 2 commits April 6, 2026 22:17

add destination validation check for empty table

d332e22

suggestions

c7ed7bd

Amogh-Bharadwaj force-pushed the pg-pg/empty-table-check branch from b7276f2 to c7ed7bd Compare April 6, 2026 16:47

serprex approved these changes Apr 6, 2026

View reviewed changes

Amogh-Bharadwaj merged commit ff25899 into main Apr 6, 2026
15 checks passed

Amogh-Bharadwaj deleted the pg-pg/empty-table-check branch April 6, 2026 17:33

pfcoperez mentioned this pull request Apr 13, 2026

Sample reports pfcoperez/whatsgoingon#1

Open

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

PG to PG: Add destination validation check for empty table#4139

PG to PG: Add destination validation check for empty table#4139
Amogh-Bharadwaj merged 2 commits intomainfrom
pg-pg/empty-table-check

Amogh-Bharadwaj commented Apr 3, 2026

Uh oh!

github-actions bot commented Apr 3, 2026

Uh oh!

Uh oh!

Uh oh!

codecov bot commented Apr 5, 2026 •

edited

Loading

Uh oh!

github-actions bot commented Apr 5, 2026

Uh oh!

github-actions bot commented Apr 6, 2026

Uh oh!

github-actions bot commented Apr 6, 2026

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Conversation

Amogh-Bharadwaj commented Apr 3, 2026

Uh oh!

github-actions bot commented Apr 3, 2026

❌ Test Failure

Uh oh!

Uh oh!

Uh oh!

codecov bot commented Apr 5, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

❌ 43 Tests Failed:

Uh oh!

github-actions bot commented Apr 5, 2026

❌ Test Failure

Uh oh!

github-actions bot commented Apr 6, 2026

🔄 Flaky Test Detected

Uh oh!

github-actions bot commented Apr 6, 2026

❌ Test Failure

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

codecov bot commented Apr 5, 2026 •

edited

Loading