From 469119180651361f8c4782dd1a2b4e4954695cb8 Mon Sep 17 00:00:00 2001 From: Terry Yin Date: Wed, 6 Mar 2024 10:13:19 -0500 Subject: [PATCH] fix typo --- dagfactory/__version__.py | 2 +- dagfactory/dagbuilder.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/dagfactory/__version__.py b/dagfactory/__version__.py index 62da8487..05480198 100644 --- a/dagfactory/__version__.py +++ b/dagfactory/__version__.py @@ -1,2 +1,2 @@ """Module contains the version of dag-factory""" -__version__ = "0.17.1.post11" +__version__ = "0.17.1.post12" diff --git a/dagfactory/dagbuilder.py b/dagfactory/dagbuilder.py index 8272e9ea..a0f758b4 100644 --- a/dagfactory/dagbuilder.py +++ b/dagfactory/dagbuilder.py @@ -712,7 +712,7 @@ def build(self) -> Dict[str, Union[str, DAG]]: if dag_class.__name__ == "PelotonDepDag": dag_kwargs["depend_on_dags"] = dag_params.get("depend_on_dags", None) dag_kwargs["wait_on_dags"] = dag_params.get("wait_on_dags", None) - dag_kwargs["depend_on_tasks"] = dag_params.get("depends_on_tasks", None) + dag_kwargs["depend_on_tasks"] = dag_params.get("depend_on_tasks", None) dag_kwargs["wait_on_tasks"] = dag_params.get("wait_on_tasks", None) dag_kwargs["alert_on_start"] = dag_params.get("alert_on_start", None) dag_kwargs["alert_on_finish"] = dag_params.get("alert_on_finish", None)