yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-13 17:59:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(ingest/airflow): fix support for bigquery insert job operator (#10567)

Browse Source
This commit is contained in:
Harshal Sheth 2024-05-21 22:38:36 -07:00 committed by GitHub
parent 40838454f5
commit ebb95b8a9a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/_extractors.py
View File

@ -203,7 +203,7 @@ def _parse_sql_into_task_metadata(
task_name = f"{self.operator.dag_id}.{self.operator.task_id}" task_name = f"{self.operator.dag_id}.{self.operator.task_id}"
run_facets = {} run_facets = {}
job_facets = {"sql": SqlJobFacet(query=self._normalize_sql(sql))} job_facets = {"sql": SqlJobFacet(query=SqlExtractor._normalize_sql(sql))}
# Prepare to run the SQL parser. # Prepare to run the SQL parser.
graph = self.context.get(_DATAHUB_GRAPH_CONTEXT_KEY, None) graph = self.context.get(_DATAHUB_GRAPH_CONTEXT_KEY, None)