Skip to content

Commit 802d4f8

Browse files
committed
Don't recursively call deregister_worker() on the current worker
Previously we were not filtering out the current worker when calling `deregister_worker()` on `workers()`.
1 parent 09533a9 commit 802d4f8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/cluster.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1185,7 +1185,7 @@ function deregister_worker(pg, pid)
11851185
# Notify the cluster manager of this workers death
11861186
manage(w.manager, w.id, w.config, :deregister)
11871187
if PGRP.topology !== :all_to_all || isclusterlazy()
1188-
for rpid in workers()
1188+
for rpid in filter(!=(myid()), workers())
11891189
try
11901190
remote_do(deregister_worker, rpid, pid)
11911191
catch

0 commit comments

Comments
 (0)