From 01bd0cebd6bd40b9c7f05fc9b92939433483f6cd Mon Sep 17 00:00:00 2001 From: VicarEscaped Date: Tue, 16 Feb 2016 17:54:30 +0300 Subject: [PATCH] Update job status with set_status --- rq/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/worker.py b/rq/worker.py index af77e4e..e29c3f1 100644 --- a/rq/worker.py +++ b/rq/worker.py @@ -592,7 +592,7 @@ class Worker(object): result_ttl = job.get_result_ttl(self.default_result_ttl) if result_ttl != 0: job.ended_at = utcnow() - job._status = JobStatus.FINISHED + job.set_status(JobStatus.FINISHED, pipeline=pipeline) job.save(pipeline=pipeline) finished_job_registry = FinishedJobRegistry(job.origin, self.connection)