diff --git a/test/distributed_exec.jl b/test/distributed_exec.jl index 56e1e13..78182e8 100644 --- a/test/distributed_exec.jl +++ b/test/distributed_exec.jl @@ -293,7 +293,9 @@ let wid1 = workers()[1], end finalize(rr) # finalize locally yield() # flush gc msgs - @test remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid) == true + if include_thread_unsafe() + @test remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid) == true + end remotecall_fetch(r -> (finalize(take!(r)); yield(); nothing), wid2, fstore) # finalize remotely sleep(0.5) # to ensure that wid2 messages have been executed on wid1 @test remotecall_fetch(k -> haskey(Distributed.PGRP.refs, k), wid1, rrid) == false