Hopiu/django-ddp
1
0
Fork 0
mirror of https://github.com/jazzband/django-ddp.git synced 2026-03-16 22:40:24 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Don't supress exceptions in pgworker greenlets.

Browse source
This commit is contained in:
Tyson Clugg 2015-12-21 20:57:11 +11:00
parent 5d1eedd75a
commit 0bcb216167
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
dddp/postgres.py
View file

@ -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."""