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 b3c6927 commit 96caf0aCopy full SHA for 96caf0a
src/workers.jl
@@ -128,15 +128,15 @@ end
128
# gracefully terminate a worker by sending a shutdown message
129
# and waiting for the other tasks to perform worker shutdown
130
function Base.close(w::Worker)
131
- @debug "closing $worker"
+ @debug "closing $(w)"
132
if !w.terminated && isopen(w.socket)
133
req = Request(Symbol(), :(), rand(UInt64), true)
134
@lock w.lock begin
135
serialize(w.socket, req)
136
flush(w.socket)
137
end
138
139
- @debug "waiting for $worker to terminate"
+ @debug "waiting for $(w) to terminate"
140
wait(w)
141
return
142
0 commit comments