Re: [PR] Set job labels for traceability [airflow]

2024-03-06 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-03-05 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-03-05 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-03-05 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-03-05 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-02-27 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-02-27 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-02-27 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-02-27 Thread via GitHub
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

Re: [PR] Set job labels for traceability [airflow]

2024-02-26 Thread via GitHub
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

[PR] Set job labels for traceability [airflow]

2024-02-26 Thread via GitHub
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