From 6be83baba33ba5f28ece5b05a78fff54b757712c Mon Sep 17 00:00:00 2001 From: Tatiana Al-Chueyr Date: Thu, 19 Dec 2024 11:56:52 +0000 Subject: [PATCH] Add debug messages --- cosmos/listeners/dag_run_listener.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cosmos/listeners/dag_run_listener.py b/cosmos/listeners/dag_run_listener.py index b65c6f409..0a1a0025a 100644 --- a/cosmos/listeners/dag_run_listener.py +++ b/cosmos/listeners/dag_run_listener.py @@ -67,8 +67,8 @@ def uses_cosmos(dag: DAG) -> bool: @hookimpl def on_dag_run_success(dag_run: DagRun, msg: str) -> None: + logger.info("The on_dag_run_success was called") dag = dag_run.get_dag() - if not uses_cosmos(dag): return @@ -87,6 +87,7 @@ def on_dag_run_success(dag_run: DagRun, msg: str) -> None: @hookimpl def on_dag_run_failed(dag_run: DagRun, msg: str) -> None: + logger.info("The on_dag_run_failed was called") dag = dag_run.get_dag() if not uses_cosmos(dag): return