pankajastro commented on issue #39541: URL: https://github.com/apache/airflow/issues/39541#issuecomment-2107167940
It is because the way we pass `nowait` param to `insert_job` method. When you are using @task then `nowait` is False but when you are using operator it is True https://github.com/apache/airflow/blob/79042cff416296c8bdbd64f2e0a5f4d46c93e882/airflow/providers/google/cloud/operators/bigquery.py#L2899-L2899 error coming from https://github.com/apache/airflow/blob/79042cff416296c8bdbd64f2e0a5f4d46c93e882/airflow/providers/google/cloud/hooks/bigquery.py#L1671-L1673 I have drafted a PR to pin the lib version until we fix it https://github.com/apache/airflow/pull/39583 -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org