yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-25 17:08:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(ingest/airflow): fix plugin support for airflow 2.5.0 (#9719)

Browse Source
This commit is contained in:
Harshal Sheth 2024-01-26 14:01:48 -08:00 committed by GitHub
parent 051f570c47
commit 388b3ec0ac
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin/_datahub_listener_module.py
View File

@ -29,6 +29,6 @@ if _listener:
if hasattr(_listener, "on_dag_run_running"):
@hookimpl
def on_dag_run_running(dag_run, session):
def on_dag_run_running(dag_run, msg):
assert _listener
_listener.on_dag_run_running(dag_run, session)
_listener.on_dag_run_running(dag_run, msg)