From 8564f1858d625e8c43c877ba6539232df92b84b3 Mon Sep 17 00:00:00 2001 From: Tomek Urbaszek Date: Mon, 5 Oct 2020 19:25:07 +0200 Subject: [PATCH] Allow dot in BigQuery job_id Closes: #11280 --- airflow/providers/google/cloud/operators/bigquery.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index f4590023d68aa..93e7db043b18a 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -2068,8 +2068,9 @@ def _job_id(self, context): if self.job_id: return f"{self.job_id}_{uniqueness_suffix}" - exec_date = re.sub(r"\:|-|\+", "_", context['execution_date'].isoformat()) - return f"airflow_{self.dag_id}_{self.task_id}_{exec_date}_{uniqueness_suffix}" + exec_date = context['execution_date'].isoformat() + job_id = f"airflow_{self.dag_id}_{self.task_id}_{exec_date}_{uniqueness_suffix}" + return re.sub(r"\:|-|\+\.", "_", job_id) def execute(self, context: Any): hook = BigQueryHook(