fix params another attempt

helxplatform · Dec 9, 2024 · af91d24 · af91d24
1 parent a6b8adc
commit af91d24
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/roger/tasks.py b/dags/roger/tasks.py
@@ -264,7 +264,7 @@ def setup_input_data(context, exec_conf):
     # Download files from lakefs and store them in this new input_path
     client = init_lakefs_client(config=config)
     repos = exec_conf['repos']
-    dag_params = context["dag"].params
+    dag_params = context["params"]
 
     if dag_params.get("repository_id"):
         logger.info(">>> repository_id supplied. Overriding repo.")