fix(ingestion/airflow-plugin): fixed linter issues

datahub-project · Jun 9, 2024 · 071b9ec · 071b9ec
1 parent 4c1ed05
commit 071b9ec
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/datahub_listener.py b/metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/datahub_listener.py
@@ -609,7 +609,9 @@ def on_dag_start(self, dag_run: "DagRun") -> None:
                         builder.make_data_job_urn_with_flow(str(flow_urn), task.task_id)
                     )
 
-            obsolete_pipelines = set(filtered_ingested_dataflow_urns) - set(airflow_flow_urns)
+            obsolete_pipelines = set(filtered_ingested_dataflow_urns) - set(
+                airflow_flow_urns
+            )
             obsolete_tasks = set(filtered_ingested_datajob_urns) - set(airflow_job_urns)
 
             obsolete_urns = obsolete_pipelines.union(obsolete_tasks)