Set user provided schedule_interval

Barski-lab · Jun 10, 2021 · 9c2c852 · 9c2c852
1 parent 8aa26f6
commit 9c2c852
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cwl_airflow/extensions/cwldag.py b/cwl_airflow/extensions/cwldag.py
@@ -103,7 +103,7 @@ def __setup_params(self, kwargs):
                 "default_args": required_default_args,
                 "on_failure_callback": kwargs.get("on_failure_callback", dag_on_failure),
                 "on_success_callback": kwargs.get("on_success_callback", dag_on_success),
-                "schedule_interval": None
+                "schedule_interval": kwargs.get("schedule_interval", None)
             }
         )