From c991553d5cf1c87035cf45d45b1c1d3ab5b3d4de Mon Sep 17 00:00:00 2001 From: admin user Date: Fri, 23 May 2025 13:06:57 +0000 Subject: [PATCH] Upload files to "expected_workflows" --- expected_workflows/flow_hybrid_expected.py | 3 --- expected_workflows/flow_parallel_expected.py | 2 -- expected_workflows/flow_sequential_expected.py | 4 ---- 3 files changed, 9 deletions(-) diff --git a/expected_workflows/flow_hybrid_expected.py b/expected_workflows/flow_hybrid_expected.py index 87d59d3..e73a22e 100644 --- a/expected_workflows/flow_hybrid_expected.py +++ b/expected_workflows/flow_hybrid_expected.py @@ -16,7 +16,6 @@ logger = logging.getLogger(__name__) class test_repo_test_branch: @temporalio.workflow.run async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]: - await temporalio.workflow.sleep(0) workflow_info = temporalio.workflow.info() workflow_output: Dict[str, Any] = { "workflow_id": workflow_info.workflow_id, @@ -242,7 +241,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Execution step 2 tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr', 'm3aiqkrv4k1y6654ymr']] results_step = await asyncio.gather(*tasks, return_exceptions=True) @@ -250,7 +248,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Update workflow status to completed if not failed if workflow_output["status"] != "failed": diff --git a/expected_workflows/flow_parallel_expected.py b/expected_workflows/flow_parallel_expected.py index ef1d659..e7fc71d 100644 --- a/expected_workflows/flow_parallel_expected.py +++ b/expected_workflows/flow_parallel_expected.py @@ -16,7 +16,6 @@ logger = logging.getLogger(__name__) class test_repo_test_branch: @temporalio.workflow.run async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]: - await temporalio.workflow.sleep(0) workflow_info = temporalio.workflow.info() workflow_output: Dict[str, Any] = { "workflow_id": workflow_info.workflow_id, @@ -240,7 +239,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Update workflow status to completed if not failed if workflow_output["status"] != "failed": diff --git a/expected_workflows/flow_sequential_expected.py b/expected_workflows/flow_sequential_expected.py index a6f338b..ef29ec6 100644 --- a/expected_workflows/flow_sequential_expected.py +++ b/expected_workflows/flow_sequential_expected.py @@ -16,7 +16,6 @@ logger = logging.getLogger(__name__) class test_repo_test_branch: @temporalio.workflow.run async def run(self, root_inputs: Dict[str, Any]) -> Dict[str, Any]: - await temporalio.workflow.sleep(0) workflow_info = temporalio.workflow.info() workflow_output: Dict[str, Any] = { "workflow_id": workflow_info.workflow_id, @@ -242,7 +241,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Execution step 2 tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr']] results_step = await asyncio.gather(*tasks, return_exceptions=True) @@ -250,7 +248,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Execution step 3 tasks = [task_functions[node_id]() for node_id in ['m3aiqkrv4k1y6654ymr']] results_step = await asyncio.gather(*tasks, return_exceptions=True) @@ -258,7 +255,6 @@ class test_repo_test_branch: if isinstance(result, Exception): logger.error(f"Task failed with exception: {result}") workflow_output["status"] = "failed" - await temporalio.workflow.sleep(0) # Update workflow status to completed if not failed if workflow_output["status"] != "failed":