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 1319e7e commit 32c662eCopy full SHA for 32c662e
src/sch/dynamic.jl
@@ -33,9 +33,18 @@ function safepoint(state)
33
if state.halt.set
34
# Force dynamic thunks and listeners to terminate
35
for (inp_chan,out_chan) in values(state.worker_chans)
36
- close(inp_chan)
37
- close(out_chan)
+ # Closing these channels will fail if the worker died, which we
+ # allow.
38
+ try
39
+ close(inp_chan)
40
+ close(out_chan)
41
+ catch ex
42
+ if !(ex isa ProcessExitedException)
43
+ rethrow()
44
+ end
45
46
end
47
+
48
# Throw out of scheduler
49
throw(SchedulerHaltedException())
50
0 commit comments