Added new job status "Running"

rq/job.py

@@ -13,7 +13,8 @@ def enum(name, *sequential, **named):
     values = dict(zip(sequential, range(len(sequential))), **named)
     return type(name, (), values)
 
-Status = enum('Status', QUEUED='queued', FINISHED='finished', FAILED='failed')
+Status = enum('Status', QUEUED='queued', FINISHED='finished', FAILED='failed',
+                        RUNNING='running')
 
 
 def unpickle(pickled_string):
@@ -105,6 +106,10 @@ class Job(object):
     def is_failed(self):
         return self.status == Status.FAILED
 
+    @property
+    def is_running(self):
+        return self.status == Status.RUNNING
+
     @property
     def func(self):
         func_name = self.func_name

rq/worker.py

@@ -320,6 +320,8 @@ class Worker(object):
                 self.state = 'busy'
 
                 job, queue = result
+                # Use the public setter here, to immediately update Redis
+                job.status = Status.RUNNING
                 self.log.info('%s: %s (%s)' % (green(queue.name),
                     blue(job.description), job.id))