From fd5092381fcf2a88476248f01dbaf59e1113183c Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Mon, 23 Sep 2013 17:56:42 +0100 Subject: [PATCH] Fixes TypeError --- kombu/async/hub.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) 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: