added more logging

helxplatform · Dec 6, 2024 · 072676b · 072676b
1 parent 9c1f03c
commit 072676b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dags/annotate_and_index.py b/dags/annotate_and_index.py
@@ -10,7 +10,7 @@
 
 from airflow.models import DAG
 from airflow.operators.empty import EmptyOperator
-from roger.tasks import default_args, create_pipeline_taskgroup
+from roger.tasks import default_args, create_pipeline_taskgroup, logger
 
 env_enabled_datasets = os.getenv(
     "ROGER_DUG__INPUTS_DATA__SETS", "topmed,anvil").split(",")
@@ -30,6 +30,8 @@
     init = EmptyOperator(task_id="init", dag=dag)
     finish = EmptyOperator(task_id="finish", dag=dag)
 
+    logger.info(f"annotate_and_index params >>> {dag.params}")
+    logger.info(f"annotate_and_index default_args >>> {dag.default_args}")
     from roger import pipelines
     from roger.config import config
     envspec = os.getenv("ROGER_DUG__INPUTS_DATA__SETS","topmed:v2.0")