make sure streaming query handle invalid sequence error

[jgao54]

Invalid sequence error is a known issue in the go-mysql-org client that needs to be classified. Previously fixed for cdc (#4197) but missing for snapshot during ExecuteSelectStreaming.

Fixes: DBI-743

[claude]

Code review

No issues found. Checked for bugs and CLAUDE.md compliance.

[codecov]

❌ 2 Tests Failed:

Tests completed	Failed	Passed	Skipped
2212	2	2210	189

View the top 2 failed test(s) by shortest run time

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

Stack Traces | 0.01s run time

=== RUN   TestApiPg
=== PAUSE TestApiPg
=== CONT  TestApiPg
--- FAIL: TestApiPg (0.01s)

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

Stack Traces | 0.12s run time

=== RUN   TestApiPg/TestResyncCompleted
=== PAUSE TestApiPg/TestResyncCompleted
=== CONT  TestApiPg/TestResyncCompleted
2026/05/14 11:33:15 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/05/14 11:33:15 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/05/14 11:33:15 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_glwcpegl.test_bit
2026/05/14 11:33:15 INFO fetched schema x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN} table=e2e_test_mychcl_e6ktn7rz.test_blobs
    api_test.go:1302: 
        	Error Trace:	.../flow/e2e/api_test.go:1302
        	Error:      	Received unexpected error:
        	            	failed to get workflow_id for flow resync_completed_api_air4qkqt: FATAL: terminating connection due to administrator command (SQLSTATE 57P01)
        	Test:       	TestApiPg/TestResyncCompleted
    api_test.go:49: begin tearing down postgres schema api_air4qkqt
--- FAIL: TestApiPg/TestResyncCompleted (0.12s)

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]

🔄 Flaky Test Detected

Analysis: TestApiPg/TestResyncCompleted failed because a Postgres connection was forcibly terminated mid-query (SQLSTATE 57P01 admin_shutdown) — an infrastructure/connection issue unrelated to the PR's mysql-streaming-error scope, characteristic of a flaky failure rather than a real bug.
Confidence: 0.9

✅ Automatically retrying the workflow

View workflow run