fix params

helxplatform · Dec 9, 2024 · 5ea0865 · 5ea0865
1 parent aff1843
commit 5ea0865
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["dag"].params
 
     if dag_params.get("repository_id"):
         repos=[{