onyx.scheduling.colocated-task-scheduler

ban-smaller-sites

(ban-smaller-sites replica jobs peer->vm task->node large-sites rejected)

choose-candidates

(choose-candidates replica peer-config this-peer downstream-peers)

find-colocated-peers

(find-colocated-peers replica this-peer other-peers)

get-peer-site

(get-peer-site replica p)

global-saturation-lower-bound

(global-saturation-lower-bound replica job-id task-ids)

large-enough-sites

(large-enough-sites site->peers-mapping min-peers)

non-colocated-tasks

(non-colocated-tasks replica jobs)

select-peers

(select-peers site->peers total size)

site->peers

(site->peers replica)