Fixes TypeError

2013-09-23 17:56:42 +01:00 · 2013-09-23 17:56:42 +01:00 · fd5092381f
parent 104de2d9f6
commit fd5092381f
1 changed files with 5 additions and 2 deletions
--- 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:
+                            try:
                                cb, cbargs = (readers.get(fileno) or
                                              writers.get(fileno))
+                            except TypeError:
+                                pass
                    except (KeyError, Empty):
                        continue
                    if cb is None: