dstandish commented on code in PR #42913:
URL: https://github.com/apache/airflow/pull/42913#discussion_r1819794180
##########
airflow/example_dags/plugins/event_listener.py:
##########
@@ -164,9 +164,10 @@ def on_dag_run_running(dag_run: DagRun, msg: str):
"""
print("Dag run in running state")
queued_at = dag_run.queued_at
- dag_hash_info = dag_run.dag_hash
- print(f"Dag information Queued at: {queued_at} hash info: {dag_hash_info}")
+ dag_version = dag_run.dag_version.version if dag_run.dag_version else None
Review Comment:
probably this could be made cleaner py putting an association proxy on dag
run, or perhaps just a property. it's just a bit clunky to have to do the if
else here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
