Skip to content

Conversation

@Amogh-Bharadwaj
Copy link
Contributor

@Amogh-Bharadwaj Amogh-Bharadwaj commented Dec 10, 2025

Useful in cases where the target data store has been deleted or is irrecoverable in some way and you want the mirror to be dropped

Screenshot 2025-12-10 at 7 28 38 PM

@codecov
Copy link

codecov bot commented Dec 10, 2025

❌ 8 Tests Failed:

Tests completed Failed Passed Skipped
1599 8 1591 144
View the top 3 failed test(s) by shortest run time
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH (0.01s)
2025/12/10 14:12:47 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:12:47 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'"
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'"
2025/12/10 14:12:47 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_11714913022779298273 CURSOR FOR \n\t\tSELECT COUNT(*) FROM peerdb_stats.flow_errors\n\t\tWHERE error_type='error' AND position('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'" args=[]
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'" channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11714913022779298273
2025/12/10 14:12:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11714913022779298273 records=1 bytes=8 channelLen=0
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'" rows=1 bytes=8 channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11714913022779298273
2025/12/10 14:12:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_11714913022779298273 records=0 bytes=0 channelLen=0
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'" rows=0 bytes=0 channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2025/12/10 14:12:47 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('test_cancel_add_cancel_api_xjyqimro' in flow_name) > 0\n\t\tAND error_message ILIKE '%while pushing to view e2e_test_api_xjyqimro.t2_mv_third%'" rows=1 bytes=8 channelLen=0
2025/12/10 14:12:47 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id"
2025/12/10 14:12:47 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id"
2025/12/10 14:12:47 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14181357463462692770 CURSOR FOR SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id" args=[]
2025/12/10 14:12:47 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id" channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14181357463462692770
2025/12/10 14:12:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14181357463462692770 records=2 bytes=76 channelLen=1
2025/12/10 14:12:47 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14181357463462692770
2025/12/10 14:12:47 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14181357463462692770 records=0 bytes=0 channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id" rows=0 bytes=0 channelLen=0
2025/12/10 14:12:47 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2025/12/10 14:12:47 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,v1,hv,sv FROM e2e_test_pgchcl_76fkje3n.\"test_pgvector\" ORDER BY id" rows=2 bytes=76 channelLen=0
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH_Cluster
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH_Cluster (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH
=== PAUSE TestPeerFlowE2ETestSuitePG_CH
=== CONT  TestPeerFlowE2ETestSuitePG_CH
--- FAIL: TestPeerFlowE2ETestSuitePG_CH (0.01s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster
Stack Traces | 0.01s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster (0.01s)
2025/12/10 14:14:30 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_yxnq2slo.test_mysql_schema_changes
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH/Test_InitialLoadOnly_No_Primary_Key
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH/Test_InitialLoadOnly_No_Primary_Key
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH/Test_InitialLoadOnly_No_Primary_Key
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH/Test_InitialLoadOnly_No_Primary_Key
2025/12/10 14:12:11 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:12:11 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:12:11 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_vhq1b71p.test_mysql_schema_changes
2025/12/10 14:12:11 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mych_wf5ctsaz.test_coercion
    clickhouse_test.go:2036: UNEXPECTED STATUS TIMEOUT STATUS_SETUP
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH/Test_InitialLoadOnly_No_Primary_Key (31.08s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH/Test_InitialLoadOnly_No_Primary_Key
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH/Test_InitialLoadOnly_No_Primary_Key
=== PAUSE TestPeerFlowE2ETestSuitePG_CH/Test_InitialLoadOnly_No_Primary_Key
=== CONT  TestPeerFlowE2ETestSuitePG_CH/Test_InitialLoadOnly_No_Primary_Key
2025/12/10 14:10:32 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:10:32 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:10:32 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id"
2025/12/10 14:10:32 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id"
2025/12/10 14:10:32 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_14251161501863678804 CURSOR FOR SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id" args=[]
2025/12/10 14:10:32 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id" channelLen=0
2025/12/10 14:10:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14251161501863678804
2025/12/10 14:10:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14251161501863678804 records=14 bytes=1516 channelLen=13
2025/12/10 14:10:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id" rows=14 bytes=1516 channelLen=0
2025/12/10 14:10:32 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14251161501863678804
2025/12/10 14:10:32 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_14251161501863678804 records=0 bytes=0 channelLen=0
2025/12/10 14:10:32 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id" rows=0 bytes=0 channelLen=0
2025/12/10 14:10:32 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2025/12/10 14:10:32 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,json,jsonb FROM e2e_test_pgch_6ipww7zl.\"test_json\" ORDER BY id" rows=14 bytes=1516 channelLen=0
    clickhouse_test.go:2036: UNEXPECTED STATUS TIMEOUT STATUS_SETUP
    clickhouse.go:114: begin tearing down postgres schema pgch_9mz43nfu
--- FAIL: TestPeerFlowE2ETestSuitePG_CH/Test_InitialLoadOnly_No_Primary_Key (31.10s)
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
Stack Traces | 31.1s run time
=== RUN   TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
=== PAUSE TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
=== CONT  TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
2025/12/10 14:14:14 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
    clickhouse_test.go:2036: UNEXPECTED STATUS TIMEOUT STATUS_SETUP
--- FAIL: TestPeerFlowE2ETestSuiteMySQL_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key (31.13s)
2025/12/10 14:14:46 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_bloajnjy.test_mysql_ghost_schema
github.com/PeerDB-io/peerdb/flow/e2e::TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
Stack Traces | 31.2s run time
=== RUN   TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
=== PAUSE TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
=== CONT  TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key
2025/12/10 14:13:09 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:13:09 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2025/12/10 14:13:09 INFO Executing and processing query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id"
2025/12/10 14:13:09 INFO Executing and processing query stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id"
2025/12/10 14:13:09 INFO [pg_query_executor] declared cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursorQuery="DECLARE peerdb_cursor_8186243503318889567 CURSOR FOR SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id" args=[]
2025/12/10 14:13:09 INFO [pg_query_executor] fetching rows start x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id" channelLen=0
2025/12/10 14:13:09 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8186243503318889567
2025/12/10 14:13:09 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8186243503318889567 records=1 bytes=8 channelLen=0
2025/12/10 14:13:09 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id" rows=1 bytes=8 channelLen=0
2025/12/10 14:13:09 INFO [pg_query_executor] fetching from cursor x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8186243503318889567
2025/12/10 14:13:09 INFO processed row stream x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart cursor=peerdb_cursor_8186243503318889567 records=0 bytes=0 channelLen=0
2025/12/10 14:13:09 INFO [pg_query_executor] fetched rows x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id" rows=0 bytes=0 channelLen=0
2025/12/10 14:13:09 INFO [pg_query_executor] committing transaction x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart
2025/12/10 14:13:09 INFO [pg_query_executor] committed transaction for query x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} partitionId=testpart query="SELECT id,c1,c2 FROM e2e_test_pgchcl_5fvbt873.\"test_nullable_sc_ch\" ORDER BY id" rows=1 bytes=8 channelLen=0
    clickhouse_test.go:2036: UNEXPECTED STATUS TIMEOUT STATUS_SETUP
    clickhouse.go:114: begin tearing down postgres schema pgchcl_7xrmqvsa
--- FAIL: TestPeerFlowE2ETestSuitePG_CH_Cluster/Test_InitialLoadOnly_No_Primary_Key (31.16s)

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants