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
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