diff options
| -rw-r--r-- | kombu/asynchronous/hub.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/asynchronous/hub.py b/kombu/asynchronous/hub.py index 262aa703..1f3478a9 100644 --- a/kombu/asynchronous/hub.py +++ b/kombu/asynchronous/hub.py @@ -305,8 +305,8 @@ class Hub(object): try: events = poll(poll_timeout) # print('[EVENTS]: %s' % (self.repr_events(events),)) - except ValueError: # Issue 882 - raise StopIteration() + except ValueError: # Issue celery/#882 + return for fd, event in events or (): general_error = False |