Add logs

astronomer · Dec 20, 2024 · 7661ab3 · 7661ab3
1 parent 940a1a2
commit 7661ab3
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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")