[PATCH compass-ci 2/2] scheduler: subqueue: submit job to subqueue

Submit the job to subqueue which related to the user, to resolve the problem that every user's job should be consumed. For example, if one user submits 1000+ jobs to queue 'vm-2p8g', another submits 1 job, it's too long time to wait to consume another's job. Signed-off-by: Ren Wen <15991987063@163.com> --- src/lib/job.cr | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/lib/job.cr b/src/lib/job.cr index a4345e0..225f9c1 100644 --- a/src/lib/job.cr +++ b/src/lib/job.cr @@ -152,6 +152,7 @@ class Job set_lkp_server() set_sshr_info() set_queue() + set_sub_queue() end private def set_kernel @@ -257,6 +258,11 @@ class Job end end + private def set_sub_queue + # queue: vm-2p8g.zs:zs@mail.com + self["queue"] = "#{self["queue"]}.#{self["my_name"]}:#{self["my_email"]}" + 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 -- 2.23.0

On Sat, Dec 05, 2020 at 08:30:57PM +0800, Ren Wen wrote:
Submit the job to subqueue which related to the user, to resolve the problem that every user's job should be consumed.
For example, if one user submits 1000+ jobs to queue 'vm-2p8g', another submits 1 job, it's too long time to wait to consume another's job.
Signed-off-by: Ren Wen <15991987063@163.com> --- src/lib/job.cr | 6 ++++++ 1 file changed, 6 insertions(+)
diff --git a/src/lib/job.cr b/src/lib/job.cr index a4345e0..225f9c1 100644 --- a/src/lib/job.cr +++ b/src/lib/job.cr @@ -152,6 +152,7 @@ class Job set_lkp_server() set_sshr_info() set_queue() + set_sub_queue() end
private def set_kernel @@ -257,6 +258,11 @@ class Job end end
+ private def set_sub_queue + # queue: vm-2p8g.zs:zs@mail.com
the example is wrong if for one user: queue: vm-2p8g~zs:zs@mail.com if default queue: queue: vm-2p8g.aarch64:zs@mail.com Thanks, Shenwei
+ self["queue"] = "#{self["queue"]}.#{self["my_name"]}:#{self["my_email"]}" + 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 -- 2.23.0

+ private def set_sub_queue + # queue: vm-2p8g.zs:zs@mail.com
the example is wrong
if for one user: queue: vm-2p8g~zs:zs@mail.com
if default queue: queue: vm-2p8g.aarch64:zs@mail.com
Thanks, Shenwei
got it. Thanks, RenWen
+ self["queue"] = "#{self["queue"]}.#{self["my_name"]}:#{self["my_email"]}" + 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 -- 2.23.0
participants (2)
-
Ren Wen
-
Xiao Shenwei