Centurion/system
2
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 9s
Details
CI Workflow / Containerize the Flow (push) Successful in 27s
Details

Browse Source
This commit is contained in:
Admin User 2025-02-25 13:51:32 +00:00
parent 9eab779b90
commit a2b927c166
3 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
expected_workflows/flow_hybrid_expected.py
View File

@ -6,6 +6,7 @@ import json
import datetime import datetime
import re import re
import jmespath import jmespath
from temporalio.exceptions import ApplicationError
# Configure logging # Configure logging
logging.basicConfig(level=logging.INFO, logging.basicConfig(level=logging.INFO,
@ -88,7 +89,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -153,7 +154,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -218,7 +219,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -252,10 +253,12 @@ class test_repo_test_branch_1234567890:
# 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":
workflow_output["status"] = "completed" workflow_output["status"] = "completed"
else:
raise ApplicationError("Activity error occurred", type="ActivityError", non_retryable=True)
return workflow_output return workflow_output
except Exception as e: except Exception as e:
logger.error(f"Workflow failed with error: {e}") logger.error(f"Workflow failed with error: {e}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
raise raise temporalio.exceptions.ApplicationError("Workflow failed",workflow_output,str(e),type="WorkflowError",non_retryable=True) from e

11
expected_workflows/flow_parallel_expected.py
View File

@ -6,6 +6,7 @@ import json
import datetime import datetime
import re import re
import jmespath import jmespath
from temporalio.exceptions import ApplicationError
# Configure logging # Configure logging
logging.basicConfig(level=logging.INFO, logging.basicConfig(level=logging.INFO,
@ -88,7 +89,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -152,7 +153,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -216,7 +217,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -243,10 +244,12 @@ class test_repo_test_branch_1234567890:
# 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":
workflow_output["status"] = "completed" workflow_output["status"] = "completed"
else:
raise ApplicationError("Activity error occurred", type="ActivityError", non_retryable=True)
return workflow_output return workflow_output
except Exception as e: except Exception as e:
logger.error(f"Workflow failed with error: {e}") logger.error(f"Workflow failed with error: {e}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
raise raise temporalio.exceptions.ApplicationError("Workflow failed",workflow_output,str(e),type="WorkflowError",non_retryable=True) from e

11
expected_workflows/flow_sequential_expected.py
View File

@ -6,6 +6,7 @@ import json
import datetime import datetime
import re import re
import jmespath import jmespath
from temporalio.exceptions import ApplicationError
# Configure logging # Configure logging
logging.basicConfig(level=logging.INFO, logging.basicConfig(level=logging.INFO,
@ -88,7 +89,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -153,7 +154,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -218,7 +219,7 @@ class test_repo_test_branch_1234567890:
block_error = { block_error = {
"code": type(e).__name__, "code": type(e).__name__,
"description": str(e), "description": str(e),
"details": {} "details": {"cause": str(getattr(e, "cause", "No additional details"))}
} }
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
# Collect block output # Collect block output
@ -259,10 +260,12 @@ class test_repo_test_branch_1234567890:
# 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":
workflow_output["status"] = "completed" workflow_output["status"] = "completed"
else:
raise ApplicationError("Activity error occurred", type="ActivityError", non_retryable=True)
return workflow_output return workflow_output
except Exception as e: except Exception as e:
logger.error(f"Workflow failed with error: {e}") logger.error(f"Workflow failed with error: {e}")
workflow_output["status"] = "failed" workflow_output["status"] = "failed"
raise raise temporalio.exceptions.ApplicationError("Workflow failed",workflow_output,str(e),type="WorkflowError",non_retryable=True) from e