[why] after one job submit, it will be add specified queue before: use tbox_group to discriminate now : use queue field to discriminate

so, we should add this field into job.yaml it's come from user's specify(job.yaml) or dafault

then put the task into the queue

Signed-off-by: Xiao Shenwei xiaoshenwei96@163.com --- src/lib/job.cr | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+)

diff --git a/src/lib/job.cr b/src/lib/job.cr index 8f5dd36..43417ea 100644 --- a/src/lib/job.cr +++ b/src/lib/job.cr @@ -139,6 +139,7 @@ class Job set_kernel_params() set_lkp_server() set_sshr_port() + set_queue() end

private def append_init_field @@ -199,6 +200,23 @@ class Job self["result_service"] = "raw_upload" end

+ private def set_queue + if @hash.has_key?("queue") + queue_prefix = @hash["queue"].to_s.split(".")[0] + if (queue_prefix != tbox_group.to_s) + raise "an incorrect queue-prefix is specified: #{queue_prefix}" + end + return + end + + # set default value + if tbox_group.to_s.starts_with?("vm") || tbox_group.to_s.starts_with?("dc") + self["queue"] = "#{tbox_group}.#{arch}" + else + self["queue"] = tbox_group + end + end + # if not assign tbox_group, set it to a match result from testbox # ?if job special testbox, should we just set tbox_group=textbox private def update_tbox_group_from_testbox