handle exception when push request

jadbin · Nov 25, 2016 · a4463b7 · a4463b7
1 parent 105ff94
commit a4463b7
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/xpaw/fetcher.py b/xpaw/fetcher.py
@@ -307,7 +307,10 @@ def from_config(cls, config):
     def push_request(self, topic, req):
         log.debug("Push request (url={0}) into the topic '{1}'".format(req.url, topic))
         r = pickle.dumps(req)
-        self._producer.send(topic, r)
+        try:
+            self._producer.send(topic, r)
+        except Exception:
+            log.warning("Unexpected error occurred when push request", exc_info=True)
 
 
 class HeartbeatSender:

diff --git a/xpaw/version.py b/xpaw/version.py
@@ -1,3 +1,3 @@
 # coding=utf-8
 
-__version__ = "0.5.5a11"
+__version__ = "0.5.5a12"