Add current_job attribute to Worker

Author: j4mie

django_dbq/management/commands/worker.py

@@ -20,6 +20,7 @@ def __init__(self, name, rate_limit_in_seconds):
         self.rate_limit_in_seconds = rate_limit_in_seconds
         self.alive = True
         self.last_job_finished = None
+        self.current_job = None
         self.init_signals()
 
     def init_signals(self):
@@ -63,6 +64,7 @@ def _process_job(self):
             )
             job.state = Job.STATES.PROCESSING
             job.save()
+            self.current_job = job
 
         try:
             task_function = import_string(job.next_task)
@@ -100,6 +102,8 @@ def _process_job(self):
             logger.exception("Failed to save job: id=%s", job.pk)
             raise
 
+        self.current_job = None
+
 
 class Command(BaseCommand):