Title add "in log" that will be more clear.

Thanks, Xueliang

On Mon, Feb 01, 2021 at 09:06:01AM +0800, Wu Zhende wrote:

The job may be closed due to timeout or other reasons

Signed-off-by: Wu Zhende wuzhende666@163.com

src/scheduler/close_job.cr | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/scheduler/close_job.cr b/src/scheduler/close_job.cr index bce6b33..b3e6716 100644 --- a/src/scheduler/close_job.cr +++ b/src/scheduler/close_job.cr @@ -8,6 +8,10 @@ class Sched

job = @redis.get_job(job_id)

• # update job_state
• job_state = @env.params.query["job_state"]?
• job["job_state"] = job_state if job_state
• response = @es.set_job_content(job) if response["_id"] == nil # es update fail, raise exception

@@ -26,7 +30,8 @@ class Sched

@redis.remove_finished_job(job_id)

• @log.info(%({"job_id": "#{job_id}", "job_state": "complete"}))

• job_state ||= "complete"
• @log.info(%({"job_id": "#{job_id}", "job_state": "#{job_state}"})) rescue e @log.warn(e) end

-- 2.23.0