On Mon, Nov 30, 2020 at 11:30:26AM +0800, Ren Wen wrote:

Field 'queue' will always have a value when initializing a Job.

when -> after.

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

src/scheduler/submit_job.cr | 5 ----- 1 file changed, 5 deletions(-)

diff --git a/src/scheduler/submit_job.cr b/src/scheduler/submit_job.cr index 2836275..c8d0875 100644 --- a/src/scheduler/submit_job.cr +++ b/src/scheduler/submit_job.cr @@ -108,11 +108,6 @@ class Sched # failure: [{"job_id" => "0", "message" => err_msg, job_state => "submit"}] def submit_single_job(job) queue = job.queue

• return [{

•  "job_id"    => "0",
  

•  "message"   => "get queue failed",
  

•  "job_state" => "submit",
  

• }] unless queue

  # only single job will has "idle job" and "execute rate limiter" if job["idle_job"].empty?

-- 2.23.0