From db913ef8ca179cf8fd9b94d555d51a2a0c905b1c Mon Sep 17 00:00:00 2001 From: AJ Date: Fri, 13 Sep 2024 14:00:07 -0400 Subject: [PATCH] remove duplicate test; reset iterations to 25 --- .../test_workflow_conductor_performance.py | 29 +------------------ 1 file changed, 1 insertion(+), 28 deletions(-) diff --git a/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py b/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py index 2bbb95ba..b14d634e 100644 --- a/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py +++ b/orquesta/tests/unit/conducting/test_workflow_conductor_performance.py @@ -76,7 +76,7 @@ def test_serialization_function_of_data_size(self): conductor.deserialize(conductor.serialize()) def test_runtime_function_of_splits_count(self): - num_tasks = 75 + num_tasks = 25 wf_def = {"input": ["data"], "tasks": {}} @@ -102,33 +102,6 @@ def test_runtime_function_of_splits_count(self): delta = t2 - t1 self.assertLess(delta.seconds, 2) - def test_inspect_performance(self): - num_tasks = 75 - - wf_def = {"input": ["data"], "tasks": {}} - - for i in range(1, num_tasks): - task_name = "t" + str(i) - next_task_name = "t" + str(i + 1) - transition = [ - {"when": "<% succeeded() %>", "do": next_task_name}, - {"when": "<% failed() %>", "do": next_task_name}, - ] - wf_def["tasks"][task_name] = {"action": "core.noop", "next": transition} - - wf_def["tasks"]["t%d" % num_tasks] = {"action": "core.noop"} - wf_def["tasks"]["t%d" % (num_tasks + 1)] = {"action": "core.noop"} - - spec = native_specs.WorkflowSpec(wf_def) - - t1 = datetime.datetime.utcnow() - self.assertDictEqual(spec.inspect(), {}) - t2 = datetime.datetime.utcnow() - - delta = t2 - t1 - self.assertLess(delta.seconds, 2) - - class WorkflowConductorWithItemsStressTest(test_base.WorkflowConductorWithItemsTest): def test_runtime_function_of_items_list_size(self): wf_def = """