From 9c2c8522c0969458915123e501591ebf15cc69f5 Mon Sep 17 00:00:00 2001 From: Michael Kotliar Date: Thu, 10 Jun 2021 11:59:43 -0400 Subject: [PATCH] Set user provided schedule_interval --- cwl_airflow/extensions/cwldag.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) } )