feat: recoverable error handlers

This commit is contained in:
Ruben Fiszel
2024-08-14 18:45:29 +02:00
parent 0eb96ded5f
commit e0857c7178
5 changed files with 28 additions and 15 deletions
@@ -1,7 +1,8 @@
export default `import os
def main(message: str, name: str):
flow_id = os.environ.get("WM_FLOW_JOB_ID")
def main(message: str, name: str, step_id: str):
flow_id = os.environ.get("WM_ROOT_FLOW_JOB_ID")
print("message", message)
print("name", name)
return message, flow_id`
print("step_id", step_id)
return { "message": message, "flow_id": flow_id, "step_id": step_id, "recover": False }`