From 38a154db21c52471841ee4afccca422f5bd5bc5d Mon Sep 17 00:00:00 2001 From: Miguel Prieto Date: Tue, 14 Jan 2025 15:28:40 -0300 Subject: [PATCH] should be plural: "dynamicTasksInputs" --- src/conductor/client/workflow/task/dynamic_fork_task.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/conductor/client/workflow/task/dynamic_fork_task.py b/src/conductor/client/workflow/task/dynamic_fork_task.py index f91d10a2..439f1660 100644 --- a/src/conductor/client/workflow/task/dynamic_fork_task.py +++ b/src/conductor/client/workflow/task/dynamic_fork_task.py @@ -9,7 +9,7 @@ class DynamicForkTask(TaskInterface): - def __init__(self, task_ref_name: str, tasks_param: str = 'dynamicTasks', tasks_input_param_name: str = 'dynamicTasksInput', join_task: JoinTask = None) -> Self: + def __init__(self, task_ref_name: str, tasks_param: str = 'dynamicTasks', tasks_input_param_name: str = 'dynamicTasksInputs', join_task: JoinTask = None) -> Self: super().__init__( task_reference_name=task_ref_name, task_type=TaskType.FORK_JOIN_DYNAMIC