dstandish commented on code in PR #42913:
URL: https://github.com/apache/airflow/pull/42913#discussion_r1819794458
##########
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
+
+ print(f"Dag information Queued at: {queued_at} hash info: {dag_version}")
Review Comment:
still says hash info
--
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]
