File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -414,6 +414,8 @@ def kill_process(
414
414
process .kill ()
415
415
process .wait ()
416
416
417
+ self ._save_output ()
418
+
417
419
def kill_all (self ) -> None :
418
420
"""Kill all running processes"""
419
421
for process in self ._processes .keys ():
Original file line number Diff line number Diff line change @@ -166,11 +166,12 @@ def _handle_exception_throw(
166
166
if not _is_running :
167
167
return
168
168
169
- self .set_status ("terminated" if _is_terminated else "failed" )
170
-
171
169
if not self ._active :
172
170
return
173
171
172
+ self .log_event (traceback or f"An exception was thrown: { _exception_thrown } " )
173
+ self .set_status ("terminated" if _is_terminated else "failed" )
174
+
174
175
# If the dispatcher has already been aborted then this will
175
176
# fail so just continue without the event
176
177
with contextlib .suppress (RuntimeError ):
@@ -1415,7 +1416,8 @@ def _tidy_run(self) -> None:
1415
1416
if self ._status == "running" :
1416
1417
if self ._dispatcher :
1417
1418
self ._dispatcher .join ()
1418
- self .set_status ("completed" )
1419
+ if self ._active :
1420
+ self .set_status ("completed" )
1419
1421
elif self ._dispatcher :
1420
1422
self ._dispatcher .purge ()
1421
1423
self ._dispatcher .join ()
You can’t perform that action at this time.
0 commit comments