Skip to content

Commit cfe8fab

Browse files
try waiting for remote isready
1 parent bf8d837 commit cfe8fab

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

test/distributed_exec.jl

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -218,6 +218,12 @@ for i in 1:max_attempts
218218

219219
@test remotecall_fetch(k->haskey(Distributed.PGRP.refs, k), wid1, fid) == true
220220

221+
w = remotecall_fetch(wid2, fstore) do x
222+
timedwait(() -> isready(fetch(x)), 10)
223+
end
224+
w == :ok || @info "isready timed out on attempt $i (max $max_attempts)"
225+
@test w == :ok
226+
221227
testval = remotecall_fetch(wid2, fstore) do x
222228
try
223229
put!(fetch(x), :OK)

0 commit comments

Comments
 (0)