From 7661ab380cec1c0a2c3c6cbe781cfa6c3babaec8 Mon Sep 17 00:00:00 2001 From: Tatiana Al-Chueyr Date: Fri, 20 Dec 2024 06:18:25 +0000 Subject: [PATCH] Add logs --- cosmos/listeners/dag_run_listener.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/cosmos/listeners/dag_run_listener.py b/cosmos/listeners/dag_run_listener.py index 15e2f2e0b..f8020e513 100644 --- a/cosmos/listeners/dag_run_listener.py +++ b/cosmos/listeners/dag_run_listener.py @@ -53,6 +53,12 @@ def on_dag_run_success(dag_run: DagRun, msg: str) -> None: dag = dag_run.get_dag() logger.info(f"dir: {dir(dag)}") + logger.info(f"1: {dag.fileloc}") + logger.info(f"2:{dag.filepath}") + logger.info(f"3: {dag.task_dict}") + logger.info(f"4: {dag.task_group_dict}") + logger.info(f"5: {dag.serialize_to_json()}") + logger.info(f"6: {dag.deserialize_dag()}") if not uses_cosmos(dag): logger.info("The DAG does not use Cosmos")