kalugin66/windmill
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add step_id to errors in flows

Browse Source
This commit is contained in:
Ruben Fiszel
2024-01-13 13:46:36 +01:00
parent f94149f401
commit eefce01f82
3 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
backend/windmill-worker/src/bun_executor.rs
View File

@@ -417,7 +417,12 @@ async function run() {{
process.exit(0);
}}
run().catch(async (e) => {{
await fs.writeFile("result.json", JSON.stringify({{ message: e.message, name: e.name, stack: e.stack }}));
let err = {{ message: e.message, name: e.name, stack: e.stack }};
let step_id = process.env.WM_FLOW_STEP_ID;
if (step_id) {{
err["step_id"] = step_id;
}}
await fs.writeFile("result.json", JSON.stringify(err));
process.exit(1);
}});
"#,

7
backend/windmill-worker/src/deno_executor.rs
View File

@@ -219,7 +219,12 @@ async function run() {{
Deno.exit(0);
}}
run().catch(async (e) => {{
await Deno.writeTextFile("result.json", JSON.stringify({{ message: e.message, name: e.name, stack: e.stack }}));
let err = {{ message: e.message, name: e.name, stack: e.stack }};
let step_id = Deno.env.get("WM_FLOW_STEP_ID");
if (step_id) {{
err["step_id"] = step_id;
}}
await Deno.writeTextFile("result.json", JSON.stringify(err));
Deno.exit(1);
}});
"#,

7
backend/windmill-worker/src/python_executor.rs
View File

@@ -280,7 +280,12 @@ except BaseException as e:
exc_type, exc_value, exc_traceback = sys.exc_info()
tb = traceback.format_tb(exc_traceback)
with open("result.json", 'w') as f:
err_json = json.dumps({{ "message": str(e), "name": e.__class__.__name__, "stack": '\n'.join(tb[1:]) }}, separators=(',', ':'), default=str).replace('\n', '')
err = {{ "message": str(e), "name": e.__class__.__name__, "stack": '\n'.join(tb[1:]) }}
import os
flow_node_id = os.environ.get('WM_FLOW_STEP_ID')
if flow_node_id:
err['step_id'] = flow_node_id
err_json = json.dumps(err, separators=(',', ':'), default=str).replace('\n', '')
f.write(err_json)
sys.exit(1)
"#,