@@ -45,7 +45,6 @@ def main(concurrency=DAEMON_CONCURRENCY, daemon=False,
try:
celeryd.run()
except Exception, e:
- raise
emergency_error(logfile, "celeryd raised exception %s: %s\n%s" % (
e.__class__, e, traceback.format_exc()))
@@ -94,8 +94,7 @@ class TaskDaemon(object):
time.sleep(self.queue_wakeup_after)
continue
except UnknownTask, e:
- self.logger.info("Unknown task requeued and ignored: %s" % (
- e))
+ self.logger.info("Unknown task ignored: %s" % (e))
self.logger.critical("Message queue raised %s: %s\n%s" % (