diff --git a/cwl_airflow/extensions/cwldag.py b/cwl_airflow/extensions/cwldag.py index 5fe7a87..4633ae8 100644 --- 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) } )