diff --git a/kombu/async/hub.py b/kombu/async/hub.py index b2a0c727..c2a10d15 100644 --- a/kombu/async/hub.py +++ b/kombu/async/hub.py @@ -232,8 +232,11 @@ class Hub(object): elif event & WRITE: cb, cbargs = writers[fileno] elif event & ERR: - cb, cbargs = (readers.get(fileno) or - writers.get(fileno)) + try: + cb, cbargs = (readers.get(fileno) or + writers.get(fileno)) + except TypeError: + pass except (KeyError, Empty): continue if cb is None: