Skip to content

Commit a5b663e

Browse files
committed
Sch: Skip not-yet-inited workers
1 parent 32b2ccd commit a5b663e

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
@@ -684,6 +684,9 @@ function schedule!(ctx, state, procs=procs_to_use(ctx))
684684
safepoint(state)
685685
@assert length(procs) > 0
686686

687+
# Remove processors that aren't yet initialized
688+
procs = filter(p -> haskey(state.worker_chans, Dagger.root_worker_id(p)), procs)
689+
687690
populate_processor_cache_list!(state, procs)
688691

689692
# Schedule tasks

0 commit comments

Comments
 (0)