Skip to content

Commit 4ef4ac2

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 8d30b83 commit 4ef4ac2

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/cluster.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1232,7 +1232,7 @@ function deregister_worker(pg, pid)
12321232
# Notify the cluster manager of this workers death
12331233
manage(w.manager, w.id, w.config, :deregister)
12341234
if PGRP.topology !== :all_to_all || isclusterlazy()
1235-
for rpid in workers()
1235+
for rpid in other_workers()
12361236
try
12371237
remote_do(deregister_worker, rpid, pid)
12381238
catch

0 commit comments

Comments
 (0)