diff options
| author | Carson Ip <carsonip715@gmail.com> | 2018-04-20 11:46:07 +0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-05-11 07:21:14 -0700 |
| commit | 257b58961f7ddd9db04d6efa070739a1b0404487 (patch) | |
| tree | 672b5110fcf1b0bfcb56d01cacf46306de6b43e8 | |
| parent | 0905c47bff3cfc42382daff0d5ac81189c8ba46d (diff) | |
| download | kazoo-257b58961f7ddd9db04d6efa070739a1b0404487.tar.gz | |
fix(core): Fix gevent 1.3b1+ timeout import
gevent.event.Timeout is undocumented and will break when using gevent 1.3b1+.
Use gevent.Timeout as suggested in gevent docs.
| -rw-r--r-- | kazoo/handlers/gevent.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kazoo/handlers/gevent.py b/kazoo/handlers/gevent.py index 551e6a0..bc721d9 100644 --- a/kazoo/handlers/gevent.py +++ b/kazoo/handlers/gevent.py @@ -60,9 +60,9 @@ class SequentialGeventHandler(object): self._state_change = Semaphore() self._workers = [] - class timeout_exception(gevent.event.Timeout): + class timeout_exception(gevent.Timeout): def __init__(self, msg): - gevent.event.Timeout.__init__(self, exception=msg) + gevent.Timeout.__init__(self, exception=msg) def _create_greenlet_worker(self, queue): def greenlet_worker(): |