Merge pull request #84 from ramielrowe/master

Distinct log message in worker exception handling
2013-04-26 12:46:11 -07:00 · 2013-04-26 12:46:11 -07:00 · 11a81b679a
commit 11a81b679a
parent 76b5953cde a2d3015bf2
1 changed files with 2 additions and 0 deletions
--- a/worker/worker.py
+++ b/worker/worker.py
@ -164,11 +164,13 @@ def run(deployment_config):
                                            queue_arguments)
                    consumer.run()
                except Exception as e:
+                    LOG.error("!!!!Exception!!!!")
                    LOG.exception("name=%s, exception=%s. Reconnecting in 5s" %
                                    (name, e))
                    time.sleep(5)
            LOG.debug("Completed processing on '%s'" % name)
        except:
+            LOG.error("!!!!Exception!!!!")
            e = sys.exc_info()[0]
            msg = "Uncaught exception: deployment=%s, exception=%s. Retrying in 5s"
            LOG.exception(msg % (name, e))