diff --git a/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py b/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py index b14d634e..29474795 100644 --- a/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py +++ b/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py @@ -62,7 +62,7 @@ def test_runtime_function_of_graph_size(self): self.forward_task_statuses(conductor, task_name, [statuses.RUNNING, statuses.SUCCEEDED]) self.assertEqual(conductor.get_workflow_status(), statuses.SUCCEEDED) - + def test_serialization_function_of_graph_size(self): num_tasks = 100 conductor = self._prep_conductor(num_tasks, status=statuses.RUNNING) @@ -101,7 +101,7 @@ def test_runtime_function_of_splits_count(self): delta = t2 - t1 self.assertLess(delta.seconds, 2) - + class WorkflowConductorWithItemsStressTest(test_base.WorkflowConductorWithItemsTest): def test_runtime_function_of_items_list_size(self): wf_def = """