Skip to content

Commit 4aac6b5

Browse files
committed
Fixing announcing run id of app run
1 parent cb5fca9 commit 4aac6b5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

nextpipe/flow.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -989,10 +989,10 @@ def __run_step(node: FlowNode, inputs: list[object], client: Client) -> list[obj
989989
run_id = app.new_run(*run_args[0], **run_args[1])
990990
console_url = f"{client.console_url}/app/{app_step.app_id}/run/{run_id}?view=details"
991991
utils.log_internal(f"Started app step {node.id} run, find it at {console_url}")
992+
node.run_id = run_id
992993
result = app.run_result_with_polling(
993994
run_id=run_id, polling_options=polling_options, output_dir_path=temp_dir
994995
)
995-
node.run_id = run_id
996996
finally: # Make sure we clean up temp dir on failure too
997997
# If the temp dir is empty, remove it
998998
dir_result = False

0 commit comments

Comments
 (0)