From 2505ded09e5e7d80cca9bd74d9df8645c97f325d Mon Sep 17 00:00:00 2001 From: fawce Date: Fri, 17 Feb 2012 12:10:36 -0500 Subject: [PATCH 1/2] added the gevent_zeromq to requirements --- etc/requirements.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/etc/requirements.txt b/etc/requirements.txt index ef46d31b..688bee9a 100644 --- a/etc/requirements.txt +++ b/etc/requirements.txt @@ -1,3 +1,3 @@ #zeromq related pyzmq==2.1.11 - +gevent-zeromq==0.2.2 From 45cbf4458f4894cb66df0697e8f6622d229c23ec Mon Sep 17 00:00:00 2001 From: Stephen Diehl Date: Fri, 17 Feb 2012 14:23:01 -0500 Subject: [PATCH 2/2] Fix for exception handling. --- zipline/messaging.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/zipline/messaging.py b/zipline/messaging.py index 623a6c0c..79e16ed5 100644 --- a/zipline/messaging.py +++ b/zipline/messaging.py @@ -64,9 +64,10 @@ class Component(object): #close all the sockets for sock in self.sockets: sock.close() - except: - qutil.LOGGER.exception("Unexpected error in run for {id}.".format(id=self.get_id())) + except Exception as e: + qutil.LOGGER.exception("Unexpected error in run for {id}.".format(id=self.get_id())) + raise e finally: self.context.destroy() @@ -476,4 +477,4 @@ class DataSource(Component): self.data_socket.send(json.dumps(event)) def get_type(self): - raise NotImplemented \ No newline at end of file + raise NotImplemented