Catch all errors in worker process and log it, don't crash

jonasvp · Jul 9, 2010 · 4defbec · 4defbec
1 parent 6aacd81
commit 4defbec
Showing 1 changed file with 15 additions and 3 deletions.
diff --git a/django_beanstalkd/management/commands/beanstalk_worker.py b/django_beanstalkd/management/commands/beanstalk_worker.py
@@ -1,3 +1,4 @@
+import logging
 from optparse import make_option
 import os
 import sys
@@ -104,9 +105,20 @@ def work(self):
                 job = beanstalk.reserve()
                 job_name = job.stats()['tube']
                 if job_name in self.jobs:
-                    #print "Calling %s with arg: %s" % (job_name, job.body)
-                    self.jobs[job_name](job.body)
-                    job.delete()
+                    logging.debug("Calling %s with arg: %s" % (job_name, job.body))
+                    try:
+                        self.jobs[job_name](job.body)
+                    except Exception, e:
+                        logging.error('Error while calling "%s" with arg "%s": '
+                            '%s' % (
+                                job_name,
+                                job.body,
+                                e,
+                            )
+                        )
+                        job.bury()
+                    else:
+                        job.delete()
                 else:
                     job.release()