From 7e4b663bbc17c53c1bd571722b79290547615251 Mon Sep 17 00:00:00 2001 From: Kiran Vasudev Date: Wed, 6 Aug 2025 18:12:35 +0200 Subject: [PATCH] parse dagrun_timeout as a timedelta instead of int --- dagger/pipeline/pipeline.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/dagger/pipeline/pipeline.py b/dagger/pipeline/pipeline.py index 32c45a2..d0d28ee 100644 --- a/dagger/pipeline/pipeline.py +++ b/dagger/pipeline/pipeline.py @@ -1,4 +1,4 @@ -from datetime import datetime +from datetime import datetime, timedelta from os.path import join, relpath from dagger import conf @@ -71,6 +71,7 @@ def __init__(self, directory: str, config: dict): self._alerts = [] self._alert_factory = AlertFactory() self.process_alerts(config["alerts"] or []) + self.process_dag_parameters(self._parameters) @property def directory(self): @@ -129,3 +130,8 @@ def process_alerts(self, alert_configs): alert_type, join(self.directory, "pipeline.yaml"), alert_config ) ) + def process_dag_parameters(self, dag_parameters):#TODO: create long term fix for this + if dag_parameters is not None: + for key, value in dag_parameters.items(): + if key == 'dagrun_timeout': + self._parameters[key] = eval(value)