Centurion/system
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Upload files to "expected_workflows"
All checks were successful
CI Workflow / Testing the Flow (push) Successful in 12s
Details
CI Workflow / Containerize the Flow (push) Successful in 18s
Details

Browse Source
This commit is contained in:
admin user 2025-05-23 12:40:38 +00:00
parent f965dcff90
commit 96c7b9f8cf
3 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
expected_workflows/flow_hybrid_expected.py
View File

@ -242,6 +242,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Execution step 2 # Execution step 2
tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr', 'm3aiqkrv4k1y6654ymr']] tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr', 'm3aiqkrv4k1y6654ymr']]
results_step = await asyncio.gather(*tasks, return_exceptions=True) results_step = await asyncio.gather(*tasks, return_exceptions=True)
@ -249,6 +250,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Update workflow status to completed if not failed # Update workflow status to completed if not failed
if workflow_output["status"] != "failed": if workflow_output["status"] != "failed":

1
expected_workflows/flow_parallel_expected.py
View File

@ -240,6 +240,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Update workflow status to completed if not failed # Update workflow status to completed if not failed
if workflow_output["status"] != "failed": if workflow_output["status"] != "failed":

3
expected_workflows/flow_sequential_expected.py
View File

@ -242,6 +242,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Execution step 2 # Execution step 2
tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr']] tasks = [task_functions[node_id]() for node_id in ['m3aiq7ixuo6du35h8tr']]
results_step = await asyncio.gather(*tasks, return_exceptions=True) results_step = await asyncio.gather(*tasks, return_exceptions=True)
@ -249,6 +250,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Execution step 3 # Execution step 3
tasks = [task_functions[node_id]() for node_id in ['m3aiqkrv4k1y6654ymr']] tasks = [task_functions[node_id]() for node_id in ['m3aiqkrv4k1y6654ymr']]
results_step = await asyncio.gather(*tasks, return_exceptions=True) results_step = await asyncio.gather(*tasks, return_exceptions=True)
@ -256,6 +258,7 @@ class test_repo_test_branch:
if isinstance(result, Exception): if isinstance(result, Exception):
logger.error(f"Task failed with exception: {result}") logger.error(f"Task failed with exception: {result}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
await temporalio.workflow.sleep(0)
# Update workflow status to completed if not failed # Update workflow status to completed if not failed
if workflow_output["status"] != "failed": if workflow_output["status"] != "failed":