From 0bcb216167ee373a2f8905c3045850300e225dde Mon Sep 17 00:00:00 2001 From: Tyson Clugg Date: Mon, 21 Dec 2015 20:57:11 +1100 Subject: [PATCH] Don't supress exceptions in pgworker greenlets. --- dddp/postgres.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/dddp/postgres.py b/dddp/postgres.py index ef8718a..419b103 100644 --- a/dddp/postgres.py +++ b/dddp/postgres.py @@ -77,7 +77,7 @@ class PostgresGreenlet(gevent.Greenlet): gevent.select.select, [conn], [], [], timeout=None, ) - self.select_greenlet.join() + self.select_greenlet.get() except gevent.GreenletExit: self._stop_event.set() finally: @@ -93,6 +93,8 @@ class PostgresGreenlet(gevent.Greenlet): self._stop_event.set() if self.select_greenlet is not None: self.select_greenlet.kill() + self.select_greenlet.get() + gevent.sleep() def poll(self, conn): """Poll DB socket and process async tasks."""