stiak commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1515232407
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2768,11 +2771,26 @@ def prepare_template(self) -> None:
with open(self.configuration) as fi
uranusjr commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1513976178
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2768,11 +2771,26 @@ def prepare_template(self) -> None:
with open(self.configuration) as
stiak commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1513643096
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2768,11 +2772,27 @@ def prepare_template(self) -> None:
with open(self.configuration) as fi
uranusjr commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1512996161
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2768,11 +2772,27 @@ def prepare_template(self) -> None:
with open(self.configuration) as
uranusjr commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1512992579
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2768,11 +2772,27 @@ def prepare_template(self) -> None:
with open(self.configuration) as
stiak commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1505112975
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2773,6 +2773,14 @@ def _submit_job(
hook: BigQueryHook,
job_id: str,
) -> BigQuer
stiak commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1505111633
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2773,6 +2773,14 @@ def _submit_job(
hook: BigQueryHook,
job_id: str,
) -> BigQuer
stiak commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1505079476
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2773,6 +2773,14 @@ def _submit_job(
hook: BigQueryHook,
job_id: str,
) -> BigQuer
amoghrajesh commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1503875260
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2773,6 +2773,14 @@ def _submit_job(
hook: BigQueryHook,
job_id: str,
) -> B
eladkal commented on code in PR #37736:
URL: https://github.com/apache/airflow/pull/37736#discussion_r1503669245
##
airflow/providers/google/cloud/operators/bigquery.py:
##
@@ -2773,6 +2773,14 @@ def _submit_job(
hook: BigQueryHook,
job_id: str,
) -> BigQu
stiak opened a new pull request, #37736:
URL: https://github.com/apache/airflow/pull/37736
This adds the airflow dag ID and task ID as labels to BigQuery jobs. This
helps trace the jobs back to their corresponding DAG from audit logs and job
history.
Let me know if t
11 matches
Mail list logo