Skip to content

Commit 7775027

Browse files
committed
fixup! datadeps: Make schedulers programmable with dispatch
1 parent a578e2f commit 7775027

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/datadeps/scheduling.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@ function datadeps_schedule_task(sched::RoundRobinScheduler, state::DataDepsState
1818
our_proc = all_procs[proc_idx]
1919
end
2020
end
21+
proc_idx = mod1(proc_idx + 1, length(all_procs))
2122
sched.proc_idx = proc_idx
2223
return our_proc
2324
end
@@ -119,4 +120,4 @@ function datadeps_schedule_task(sched::UltraScheduler, state::DataDepsState, all
119120
sched.task_completions[task] = our_space_completed + move_time + task_time
120121

121122
return our_proc
122-
end
123+
end

0 commit comments

Comments
 (0)