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
# 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:
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
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
-
Liu Shaofei -
Ren Wen