Skip to content

Commit ecd83b2

Browse files
committed
fixup! Add support for worker state callbacks
1 parent 0d5aaa3 commit ecd83b2

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

test/distributed_exec.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1995,14 +1995,15 @@ end
19951995

19961996
# Test that workers that were killed forcefully are detected as such
19971997
exit_state = nothing
1998-
DistributedNext.add_worker_exited_callback((pid, state) -> exit_state = state)
1998+
exited_key = DistributedNext.add_worker_exited_callback((pid, state) -> exit_state = state)
19991999
pid = only(addprocs(1))
20002000

20012001
redirect_stderr(devnull) do
20022002
remote_do(exit, pid)
20032003
timedwait(() -> !isnothing(exit_state), 10)
20042004
end
20052005
@test exit_state == DistributedNext.WorkerState_exterminated
2006+
DistributedNext.remove_worker_exited_callback(exited_key)
20062007
end
20072008

20082009
# This is a simplified copy of a test from Revise.jl's tests

0 commit comments

Comments
 (0)