registry.cleanup() now writes information to job.exc_info (#1226)

rq/registry.py

@@ -135,6 +135,7 @@ class StartedJobRegistry(BaseRegistry):
                         job = self.job_class.fetch(job_id,
                                                    connection=self.connection)
                         job.set_status(JobStatus.FAILED)
+                        job.exc_info = "Moved to FailedJobRegistry at %s" % datetime.now()
                         job.save(pipeline=pipeline, include_meta=False)
                         job.cleanup(ttl=-1, pipeline=pipeline)
                         failed_job_registry.add(job, job.failure_ttl)

rq/worker.py

@@ -724,7 +724,7 @@ class Worker(object):
 
             self.handle_job_failure(
                 job,
-                exc_string="Work-horse process was terminated unexpectedly "
+                exc_string="Work-horse was terminated unexpectedly "
                            "(waitpid returned %s)" % ret_val
             )
 

tests/test_registry.py

@@ -152,6 +152,7 @@ class TestRegistry(RQTestCase):
         self.assertNotIn(job, self.registry)
         job.refresh()
         self.assertEqual(job.get_status(), JobStatus.FAILED)
+        self.assertTrue(job.exc_info)  # explanation is written to exc_info 
 
     def test_job_execution(self):
         """Job is removed from StartedJobRegistry after execution."""