diff --git a/beeflow/tests/test_wf_interface.py b/beeflow/tests/test_wf_interface.py index 841cdfb1..84d9d53e 100644 --- a/beeflow/tests/test_wf_interface.py +++ b/beeflow/tests/test_wf_interface.py @@ -229,7 +229,7 @@ def test_restart_task(self): task_state = "WAITING" - self.wfi.add_task(taski, task_state) + self.wfi.add_task(task, task_state) # Restart the task, should create a new Task new_task = self.wfi.restart_task(task, test_checkpoint_file)