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