Skip to content

Commit 8d04144

Browse files
committed
Sch: Skip not-yet-inited workers
1 parent 73a24ad commit 8d04144

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
@@ -678,6 +678,9 @@ function schedule!(ctx, state, procs=procs_to_use(ctx))
678678
safepoint(state)
679679
@assert length(procs) > 0
680680

681+
# Remove processors that aren't yet initialized
682+
procs = filter(p -> haskey(state.worker_chans, Dagger.root_worker_id(p)), procs)
683+
681684
populate_processor_cache_list!(state, procs)
682685

683686
# Schedule tasks

0 commit comments

Comments
 (0)