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

...

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 == "" ?

No need. According to context.

Thanks, RenWen

 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