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

Update templates/workflow_template.py.j2
Some checks failed
CI Workflow / Testing the Flow (push) Failing after 12s
Details
CI Workflow / Containerize the Flow (push) Has been skipped
Details

Browse Source
This commit is contained in:
Admin User 2025-02-25 13:23:16 +00:00
parent 9533ce1f86
commit 9eab779b90
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
templates/workflow_template.py.j2
View File

@ -6,6 +6,7 @@ import json
import datetime
import re
import jmespath
from temporalio.exceptions import ApplicationError
# Configure logging
logging.basicConfig(level=logging.INFO,
@ -111,7 +112,7 @@ class {{ workflow_class_name }}:
block_error = {
"code": type(e).__name__,
"description": str(e),
"details": {}
"details": {"cause": str(getattr(e, "cause", "No additional details"))}
}
workflow_output["status"] = "failed"
# Collect block output
@ -141,10 +142,12 @@ class {{ workflow_class_name }}:
# Update workflow status to completed if not failed
if workflow_output["status"] != "failed":
workflow_output["status"] = "completed"
else:
raise ApplicationError("Activity error occurred", type="ActivityError", non_retryable=True)
return workflow_output
except Exception as e:
logger.error(f"Workflow failed with error: {e}")
workflow_output["status"] = "failed"
raise
raise temporalio.exceptions.ApplicationError("Workflow failed",workflow_output,str(e),type="WorkflowError",non_retryable=True) from e