'queue' will always have the value after initializing the Job.

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?