From 2be833c4d1924818e31e1255cdee0beb12633289 Mon Sep 17 00:00:00 2001 From: JamesWrigley Date: Wed, 22 Jan 2025 14:25:50 +0100 Subject: [PATCH] fixup! Replace a timeout task with timedwait() --- src/cluster.jl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/cluster.jl b/src/cluster.jl index 2e50376..43303b2 100644 --- a/src/cluster.jl +++ b/src/cluster.jl @@ -194,7 +194,7 @@ function wait_for_conn(w) timeout = worker_timeout() - (time() - w.ct_time) timeout <= 0 && error("peer $(w.id) has not connected to $(myid())") - if timedwait(() -> (@atomic w.state) === WorkerState_connected, timeout) === :timed_out + if timedwait(() -> (@atomic w.state) === W_CONNECTED, timeout) === :timed_out # Notify any waiters on the state and throw @lock w.c_state notify(w.c_state) error("peer $(w.id) didn't connect to $(myid()) within $timeout seconds")