(airflow) branch main updated: Refactor bigquery_async_query test (#72193)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new db815a56abb Refactor bigquery_async_query test (#72193)
db815a56abb is described below

commit db815a56abbb0b3fc892c12dd3eaad649c45e2c4
Author: olegkachur-e <qws...@gmail.com>
AuthorDate: Fri Aug 28 14:26:11 2026 +0000

    Refactor bigquery_async_query test (#72193)
    
    Improve test stability by making the insert SQL query idempotent.
    This prevents downstream 'check_*' tasks from failing due to multiple 
inserts upon a task retry.
    
    Co-authored-by: Oleg Kachur <kac...@google.com>
---
 .../system/google/cloud/bigquery/example_bigquery_queries_async.py     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/providers/google/tests/system/google/cloud/bigquery/example_bigquery_queries_async.py
 
b/providers/google/tests/system/google/cloud/bigquery/example_bigquery_queries_async.py
index 366adfc6bb8..60080989320 100644
--- 
a/providers/google/tests/system/google/cloud/bigquery/example_bigquery_queries_async.py
+++ 
b/providers/google/tests/system/google/cloud/bigquery/example_bigquery_queries_async.py
@@ -65,7 +65,8 @@ SCHEMA = [
 
 INSERT_DATE = "2030-01-01"
 INSERT_ROWS_QUERY = (
-    f"INSERT {DATASET_NAME}.{TABLE_NAME_1} VALUES "
+    f"TRUNCATE TABLE `{DATASET_NAME}.{TABLE_NAME_1}`; "
+    f"INSERT INTO `{DATASET_NAME}.{TABLE_NAME_1}` VALUES "
     f"(42, 'monty python', '{INSERT_DATE}'), "
     f"(42, 'fishy fish', '{INSERT_DATE}');"
 )