Skip to content

Commit 6fd25c4

Browse files
committed
Sch: Quietly fail to put do_tasks exception
1 parent 13ac291 commit 6fd25c4

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/sch/Sch.jl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -905,7 +905,9 @@ function (ets::FireTaskSpec)()
905905
bt = catch_backtrace()
906906
# FIXME: Catch the correct task ID
907907
thunk_id = first_task.thunk_id
908-
put!(chan, TaskResult(pid, proc, thunk_id, CapturedException(err, bt), nothing))
908+
if isopen(chan)
909+
put!(chan, TaskResult(pid, proc, thunk_id, CapturedException(err, bt), nothing))
910+
end
909911
finally
910912
@maybelog ctx timespan_finish(ctx, :fire, (;uid, worker=pid), nothing)
911913
end

0 commit comments

Comments
 (0)