[airflow] branch main updated: Wait insert_job result in normal mode (#29925)

[po...@apache.org]

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 464ab1b7ca Wait insert_job result in normal mode (#29925)
464ab1b7ca is described below

commit 464ab1b7caa78637975008fcbb049d5b52a8b005
Author: Hussein Awala <ho...@gmail.com>
AuthorDate: Sun Mar 5 11:40:38 2023 +0100

    Wait insert_job result in normal mode (#29925)
---
 airflow/providers/google/cloud/transfers/bigquery_to_gcs.py    | 2 +-
 tests/providers/google/cloud/transfers/test_bigquery_to_gcs.py | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py b/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py
index 62cb8f76dd..e12c0c2d4e 100644
--- a/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py
+++ b/airflow/providers/google/cloud/transfers/bigquery_to_gcs.py
@@ -197,7 +197,7 @@ class BigQueryToGCSOperator(BaseOperator):
             job_id=job_id,
             timeout=self.result_timeout,
             retry=self.result_retry,
-            nowait=True,
+            nowait=self.deferrable,
         )
 
     def execute(self, context: Context):
diff --git a/tests/providers/google/cloud/transfers/test_bigquery_to_gcs.py b/tests/providers/google/cloud/transfers/test_bigquery_to_gcs.py
index 3360084642..b1d0563f58 100644
--- a/tests/providers/google/cloud/transfers/test_bigquery_to_gcs.py
+++ b/tests/providers/google/cloud/transfers/test_bigquery_to_gcs.py
@@ -87,7 +87,7 @@ class TestBigQueryToGCSOperator:
             location=None,
             timeout=None,
             retry=DEFAULT_RETRY,
-            nowait=True,
+            nowait=False,
         )
 
     @mock.patch("airflow.providers.google.cloud.transfers.bigquery_to_gcs.BigQueryHook")