Skip to content

Commit cd09127

Browse files
Fix issue where stdout is not captured when task fails
1 parent a8645ca commit cd09127

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

scheduler/Scheduler.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -596,6 +596,9 @@ def wrapper(
596596
queue.put(out)
597597

598598
except Exception as e:
599+
if stdout:
600+
stdout.update(force=True)
601+
599602
if exc_queue:
600603
tb = (
601604
f"{type(e)}\n"

0 commit comments

Comments
 (0)