Signed-off-by: Cao Xueliang <caoxl78320@163.com> --- src/scheduler/find_job_boot.cr | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/scheduler/find_job_boot.cr b/src/scheduler/find_job_boot.cr index f8d7caa..9e2898e 100644 --- a/src/scheduler/find_job_boot.cr +++ b/src/scheduler/find_job_boot.cr @@ -75,13 +75,15 @@ class Sched end idle_queues = [] of String + delimiter_queues = [] of String default_queues.each do |queue| idle_queues << "#{queue}/idle" + delimiter_queues << "#{queue}/delimiter@localhost" end - all_queues = rand_queues(sub_queues) + idle_queues + all_queues = delimiter_queues + rand_queues(sub_queues) + idle_queues - return all_queues + return all_queues.uniq end def get_job_from_queues(queues, testbox) -- 2.23.0