From 596065add1544c714621df4839d00c7692cac3d9 Mon Sep 17 00:00:00 2001 From: Peng Gao Date: Tue, 6 Feb 2024 17:39:38 -0800 Subject: [PATCH] update --- .../src/datahub_airflow_plugin/client/airflow_generator.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/client/airflow_generator.py b/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/client/airflow_generator.py index eca8feb0a5c9fc..e2c7ea8afa6194 100644 --- a/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/client/airflow_generator.py +++ b/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/client/airflow_generator.py @@ -209,7 +209,7 @@ def generate_datajob( set_dependencies: bool = True, capture_owner: bool = True, capture_tags: bool = True, - config: DatahubLineageConfig = DatajobUrl.TASKINSTANCE, + config: DatahubLineageConfig = None, ) -> DataJob: """ @@ -297,7 +297,7 @@ def create_datajob_instance( task: "Operator", dag: "DAG", data_job: Optional[DataJob] = None, - config: DatahubLineageConfig = DatajobUrl.TASKINSTANCE, + config: DatahubLineageConfig = None, ) -> DataProcessInstance: if data_job is None: data_job = AirflowGenerator.generate_datajob(