We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0879d2b commit 6c774a1Copy full SHA for 6c774a1
src/torchrunx/launcher.py
@@ -181,7 +181,6 @@ def launch(
181
else:
182
e += f"{v.message['message']}\n"
183
e += f"{v.message['extraInfo']['py_callstack']}\n\n"
184
- print_process.kill()
185
raise RuntimeError(e)
186
except:
187
# kill all agents
@@ -191,9 +190,9 @@ def launch(
191
190
hostname=agent_hostname,
192
ssh_config_file=ssh_config_file,
193
)
194
195
raise
+ finally:
+ print_process.kill()
196
197
- print_process.kill() # TODO: or close?
198
return_values: dict[int, Any] = dict(ChainMap(*[s.return_values for s in agent_statuses]))
199
return return_values
0 commit comments