otel spans for cdc.batch: pull/sync/normalize

[serprex]

No description provided.

[claude]

Code review

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

[codecov]

❌ 2 Tests Failed:

Tests completed	Failed	Passed	Skipped
2229	2	2227	206

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

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

Stack Traces | 33.8s run time

=== RUN   TestGenericBQ/Test_Simple_Flow
=== PAUSE TestGenericBQ/Test_Simple_Flow
=== CONT  TestGenericBQ/Test_Simple_Flow
    generic_test.go:125: UNEXPECTED STATUS TIMEOUT STATUS_SNAPSHOT
    bigquery.go:86: begin tearing down postgres schema bq_cci0yc0m_20260523203938
--- FAIL: TestGenericBQ/Test_Simple_Flow (33.84s)

View the full list of 1 ❄️ flaky test(s)

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

Flake rate in main: 22.86% (Passed 54 times, Failed 16 times)

Stack Traces | 0s run time

=== RUN   TestGenericBQ
=== PAUSE TestGenericBQ
=== CONT  TestGenericBQ
--- FAIL: TestGenericBQ (0.00s)
2026/05/23 20:41:26 INFO Received AWS credentials from peer for connector: ci x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}
2026/05/23 20:41:26 INFO Received AWS credentials from peer for connector: clickhouse x-peerdb-additional-metadata={Operation:FLOW_OPERATION_UNKNOWN}

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: TestGenericPG/Test_Simple_Flow timed out waiting for STATUS_SNAPSHOT transition on a single matrix shard (mysql-gtid); the recent commit touched BigQuery error classification, unrelated to this Postgres generic flow test, indicating a snapshot-progression timing flake.
Confidence: 0.88

✅ Automatically retrying the workflow

View workflow run

[ilidemi]

Great change, covers a good amount of DBI-575 which we can add on top

[github-actions]

❌ Test Failure

Analysis: Build fails to compile due to undefined identifier otel_metrics.BatchIdKey referenced in activities/flowable_core.go (lines 296, 297, 731), affecting all matrix jobs — a real code bug, not a flaky test.
Confidence: 0.99

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

View workflow run

[github-actions]

❌ Test Failure

Analysis: Real bug: compilation fails with "undefined: otel_metrics.BatchIdKey" referenced from activities/flowable_core.go at multiple lines (226, 235, 296, 733), so tests never ran.
Confidence: 0.98

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

View workflow run

[github-actions]

🔄 Flaky Test Detected

Analysis: TestApiPg/TestTotalRowsSyncedByMirror failed due to the catalog Postgres terminating the connection (SQLSTATE 57P01 admin_shutdown) and a follow-on replication-slot-still-active teardown race; the same tests passed in the parallel mysql-gtid and mysql-pos matrix legs of this PR, indicating an infrastructure flake rather than a code bug.
Confidence: 0.9

✅ Automatically retrying the workflow

View workflow run

[github-actions]

🔄 Flaky Test Detected

Analysis: TestGenericBQ/Test_Simple_Flow timed out during STATUS_SNAPSHOT (1 of 2435 tests failed), matching the codebase's already-documented BigQuery snapshot-phase flakiness and unrelated to the latest commit (a Mongo struct field alignment fix).
Confidence: 0.9

✅ Automatically retrying the workflow

View workflow run

[github-actions]

🔄 Flaky Test Detected

Analysis: TestApiPg/TestQRep failed with SQLSTATE 57P01 ("terminating connection due to administrator command") — a connection-level Postgres shutdown that only hit the maria matrix entry while mysql-pos/mysql-gtid passed, characteristic of infrastructure flakiness rather than a real bug.
Confidence: 0.85

✅ Automatically retrying the workflow

View workflow run