yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-13 02:57:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(airflow): fix lint related to dag_run field (#11616)

Browse Source
This commit is contained in:
Harshal Sheth 2024-10-15 01:39:41 -07:00 committed by GitHub
parent 0d06a61365
commit be1b8806a7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/datahub_listener.py
View File

@ -383,13 +383,11 @@ class DataHubListener:
return return
logger.debug( logger.debug(
f"DataHub listener got notification about task instance start for {task_instance.task_id} of dag {task_instance.dag_run.dag_id}" f"DataHub listener got notification about task instance start for {task_instance.task_id} of dag {task_instance.dag_id}"
) )
if not self.config.dag_filter_pattern.allowed(task_instance.dag_run.dag_id): if not self.config.dag_filter_pattern.allowed(task_instance.dag_id):
logger.debug( logger.debug(f"DAG {task_instance.dag_id} is not allowed by the pattern")
f"DAG {task_instance.dag_run.dag_id} is not allowed by the pattern"
)
return return
if self.config.render_templates: if self.config.render_templates: