feat(csharp): emit per-statement telemetry on the SEA path (PECO-3022) by jadewang-db · Pull Request #464 · adbc-drivers/databricks

Refactor ConnectionTelemetry.Create to take string sessionId and DriverMode\n\nTask ID: task-1.1-refactor-connection-telemetry-create

Jade Wang

committed

[gap-fill][gap-8] Update sprint plan stale file paths

Jade Wang

committed

[gap-fill][gap-1] Align driver_name string across SEA and Thrift

Jade Wang

committed

Address PR review feedback on ConnectionTelemetry.Create refactor

Jade Wang

committed

Define IStatementOperationObserver interface and NullObserver singleton\n\nTask ID: task-2.1-observer-interface-and-null-impl

Jade Wang

committed

Implement TelemetryObserver translating callbacks to StatementTelemetryContext + enqueue\n\nTask ID: task-2.2-telemetry-observer-impl

Jade Wang

committed

Add SafeObserver decorator that swallows exceptions from any inner observer\n\nTask ID: task-2.3-safe-observer-decorator

Jade Wang

committed

Refactor DatabricksStatement to use IStatementOperationObserver field\n\nTask ID: task-3.1-refactor-databricks-statement-observer

Jade Wang

committed

[gap-fill][gap-7] Formalize reader-inspection hook to remove PendingTelemetryContext downcast

Jade Wang

committed

Wire IConnectionTelemetry into StatementExecutionConnection\n\nTask ID: task-4.1-wire-sea-connection-telemetry

Jade Wang

committed

[gap-fill][gap-6] Fix connectTimeoutMilliseconds source in SEA telemetry init

Jade Wang

committed

[gap-fill][gap-2] Verify socket_timeout uses real connect-timeout (not _waitTimeoutSeconds) in SEA

Jade Wang

committed

[gap-fill][gap-1] Honor ConnectTimeoutMilliseconds in SEA HttpClient (B11)

Jade Wang

committed

[gap-fill][gap-2] Emit enable_direct_results from user property on SEA (B10)

Jade Wang

committed

Add IStatementOperationObserver field to StatementExecutionStatement and inject from connection\n\nTask ID: task-5.1-sea-statement-observer-field-and-create

Jade Wang

committed

Wire OnExecuteStarted, OnExecuteSucceeded, and OnPollCompleted into SEA statement\n\nTask ID: task-5.2-sea-statement-execute-and-poll-hookpoints

Jade Wang

committed

[gap-fill][gap-1] Wire OnFinalized into StatementExecutionStatement.Dispose

Jade Wang

committed

[gap-fill][gap-2] Implement SeaResultFormatMapper and use in OnExecuteSucceeded

Jade Wang

committed

[gap-fill][gap-3] Wire OnFirstBatchReady at SEA reader construction

Jade Wang

committed

[gap-fill][gap-4] Wire OnConsumed at SEA reader Dispose

Jade Wang

committed

[gap-fill][gap-5] Wire OnChunksDownloaded for SEA cloud-fetch path

Jade Wang

committed

[gap-fill][gap-3] Use EXECUTE_STATEMENT_ASYNC operation type for SEA

Jade Wang

committed

[gap-fill][gap-4] Ensure reader latencies fire on 100% of successful SEA EXECUTE records

Jade Wang

committed

[gap-fill][gap-5] Emit CLOSE_STATEMENT operation event from SEA statement Dispose

Jade Wang

committed

[gap-fill][G4] Enable E2E telemetry tests for SEA protocol

Jade Wang

committed

PECO-3022 docs: commit SEA telemetry gap reports

Jade Wang

committed

[gap-fill][gap-3] Wire observer lifecycle into SEA ExecuteUpdate path (B9)

Jade Wang

committed

[gap-fill] Close PECO-3022 B8/B10/B11 — metadata op types, enable_direct_results, ConnectTimeoutMilliseconds

Jade Wang

committed

PECO-3022 docs: close B8/B9/B10/B11 in e2e-comparator gap report

Jade Wang

committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

feat(csharp): emit per-statement telemetry on the SEA path (PECO-3022)#464

feat(csharp): emit per-statement telemetry on the SEA path (PECO-3022)#464
jadewang-db wants to merge 29 commits into
mainfrom
stack/pr-phase5-sea-statement-telemetry

Commits on May 22, 2026

Refactor ConnectionTelemetry.Create to take string sessionId and DriverMode\n\nTask ID: task-1.1-refactor-connection-telemetry-create

[gap-fill][gap-8] Update sprint plan stale file paths

[gap-fill][gap-1] Align driver_name string across SEA and Thrift

Address PR review feedback on ConnectionTelemetry.Create refactor

Define IStatementOperationObserver interface and NullObserver singleton\n\nTask ID: task-2.1-observer-interface-and-null-impl

Implement TelemetryObserver translating callbacks to StatementTelemetryContext + enqueue\n\nTask ID: task-2.2-telemetry-observer-impl

Add SafeObserver decorator that swallows exceptions from any inner observer\n\nTask ID: task-2.3-safe-observer-decorator

Refactor DatabricksStatement to use IStatementOperationObserver field\n\nTask ID: task-3.1-refactor-databricks-statement-observer

[gap-fill][gap-7] Formalize reader-inspection hook to remove PendingTelemetryContext downcast

Wire IConnectionTelemetry into StatementExecutionConnection\n\nTask ID: task-4.1-wire-sea-connection-telemetry

[gap-fill][gap-6] Fix connectTimeoutMilliseconds source in SEA telemetry init

[gap-fill][gap-2] Verify socket_timeout uses real connect-timeout (not _waitTimeoutSeconds) in SEA

[gap-fill][gap-1] Honor ConnectTimeoutMilliseconds in SEA HttpClient (B11)

[gap-fill][gap-2] Emit enable_direct_results from user property on SEA (B10)

Add IStatementOperationObserver field to StatementExecutionStatement and inject from connection\n\nTask ID: task-5.1-sea-statement-observer-field-and-create

Wire OnExecuteStarted, OnExecuteSucceeded, and OnPollCompleted into SEA statement\n\nTask ID: task-5.2-sea-statement-execute-and-poll-hookpoints

[gap-fill][gap-1] Wire OnFinalized into StatementExecutionStatement.Dispose

[gap-fill][gap-2] Implement SeaResultFormatMapper and use in OnExecuteSucceeded

[gap-fill][gap-3] Wire OnFirstBatchReady at SEA reader construction

[gap-fill][gap-4] Wire OnConsumed at SEA reader Dispose

[gap-fill][gap-5] Wire OnChunksDownloaded for SEA cloud-fetch path

[gap-fill][gap-3] Use EXECUTE_STATEMENT_ASYNC operation type for SEA

[gap-fill][gap-4] Ensure reader latencies fire on 100% of successful SEA EXECUTE records

[gap-fill][gap-5] Emit CLOSE_STATEMENT operation event from SEA statement Dispose

[gap-fill][G4] Enable E2E telemetry tests for SEA protocol

PECO-3022 docs: commit SEA telemetry gap reports

[gap-fill][gap-3] Wire observer lifecycle into SEA ExecuteUpdate path (B9)

[gap-fill] Close PECO-3022 B8/B10/B11 — metadata op types, enable_direct_results, ConnectTimeoutMilliseconds

PECO-3022 docs: close B8/B9/B10/B11 in e2e-comparator gap report