Skip to content

Commit 2f2852f

Browse files
fix thread unsafe test
1 parent 109da4d commit 2f2852f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

test/distributed_exec.jl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -302,8 +302,8 @@ let wid1 = workers()[1],
302302
finalize(rr) # finalize locally
303303
yield() # flush gc msgs
304304
if include_thread_unsafe_tests()
305-
@test remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid) == true
306305
end
306+
@test timedwait(() -> remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid), 10) === :ok
307307
remotecall_fetch(r -> (finalize(take!(r)); yield(); nothing), wid2, fstore) # finalize remotely
308308
sleep(0.5) # to ensure that wid2 messages have been executed on wid1
309309
@test poll_while(() -> remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid))

0 commit comments

Comments
 (0)