Skip to content

Commit 23373c0

Browse files
committed
Sch: Skip not-yet-inited workers
1 parent fc1c1b1 commit 23373c0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/sch/Sch.jl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -680,6 +680,9 @@ function schedule!(ctx, state, procs=procs_to_use(ctx))
680680
safepoint(state)
681681
@assert length(procs) > 0
682682

683+
# Remove processors that aren't yet initialized
684+
procs = filter(p -> haskey(state.worker_chans, Dagger.root_worker_id(p)), procs)
685+
683686
populate_processor_cache_list!(state, procs)
684687

685688
# Schedule tasks

0 commit comments

Comments
 (0)