[Compass-ci] Re: [PATCH compass-ci] scheduler: submit cluster job to queue/subqueue

On Mon, Dec 14, 2020 at 05:13:29PM +0800, Ren Wen wrote:

Signed-off-by: Ren Wen 15991987063@163.com

src/scheduler/submit_job.cr | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/scheduler/submit_job.cr b/src/scheduler/submit_job.cr index 4303b1d..c322d0f 100644 --- a/src/scheduler/submit_job.cr +++ b/src/scheduler/submit_job.cr @@ -37,6 +37,7 @@ class Sched def submit_cluster_job(job, cluster_config) job_messages = Array(Hash(String, String)).new lab = job.lab

• subqueue = job.subqueue

whether need judge job is nil , or job.subqueue == "" ? Thanks, Liushaofei

# collect all job ids
job_ids = [] of String

@@ -52,7 +53,7 @@ class Sched # steps for each host cluster_config["nodes"].as_h.each do |host, config| queue = host.to_s

•  job_id = add_task(queue, lab)
  

•  job_id = add_task("#{queue}/#{subqueue}", lab)
  
  # return when job_id is '0'
  # 2 Questions:
  

-- 2.23.0