radhwene commented on PR #61148: URL: https://github.com/apache/airflow/pull/61148#issuecomment-3876173310
## System Test Results I ran a standalone test script against a live GCP project to validate the `BigQueryStreamingBufferEmptySensor` behavior end-to-end. ### Test Flow 1. Create dataset & table in BigQuery 2. Insert rows via **Streaming API** (`insert_rows_json`) 3. Confirm streaming buffer is **active** (~3 rows, ~400 bytes) 4. Sensor `poke()` polls every 30s until buffer is flushed 5. Run **DML UPDATE** to confirm buffer is clear 6. Cleanup (delete dataset) ### Screenshot <img width="704" height="300" alt="image" src="https://github.com/user-attachments/assets/88360e20-2c21-4398-93db-692eab42d159"; /> ### Tested on: - Airflow 2.10.3 / Python 3.12 - google-cloud-bigquery SDK - GCP project with BigQuery API enabled -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
