add worker desc in Failure

Author: fakechris

src/pyres/failure.py

@@ -2,12 +2,12 @@
 from pyres import ResQ 
 import sys, traceback
 class Failure(object):
-    def __init__(self, exp, queue, payload):
+    def __init__(self, exp, worker, queue, payload):
         excc, _, tb = sys.exc_info()
 
         self._exception = excc
         self._traceback = tb
-        #self._worker = worker
+        self._worker = worker
         self._queue = queue
         self._payload = payload
 
@@ -30,7 +30,8 @@ def save(self, resq):
             'payload'   : self._payload,
             'error'     : self._parse_message(self._exception),
             'backtrace' : self._parse_traceback(self._traceback),
-            'queue'     : self._queue
+            'queue'     : self._queue,
+            'worker'    : self._worker
         }
         data = ResQ.encode(data)
         resq.redis.push('resque:failed', data)

src/pyres/job.py

@@ -1,10 +1,11 @@
 from pyres import ResQ, str_to_class
 from pyres.failure import Failure
 class Job(object):
-    def __init__(self, queue, payload, resq):
+    def __init__(self, queue, payload, resq, worker):
         self._queue = queue
         self._payload = payload
         self.resq = resq
+        self._worker = worker
 
     def perform(self):
         payload_class_str = self._payload["class"]
@@ -17,11 +18,11 @@ def perform(self):
 
     def fail(self, exception):
         #Failure.create(exception)
-        failure = Failure(exception, self._queue, self._payload)
+        failure = Failure(exception, self._worker, self._queue, self._payload)
         failure.save(self.resq)
 
     @classmethod
-    def reserve(cls, queue, res):
+    def reserve(cls, queue, res, worker):
         payload = res.pop(queue)
         if payload:
-            return cls(queue, payload, res)
+            return cls(queue, payload, res, worker)

src/pyres/worker.py

@@ -128,7 +128,7 @@ def process(self, job=None):
     def reserve(self):
         for q in self.queues:
             print "Checking %s" % q
-            job = Job.reserve(q, self.resq)
+            job = Job.reserve(q, self.resq, self.__str__())
             if job:
                 print "Found job on %s" % q
                 return job