Call errbacks with future.exception

2016-01-03 23:31:09 -08:00
parent 54d758e813
commit bb433e27f0
1 changed files with 1 additions and 1 deletions
--- a/kafka/future.py
+++ b/kafka/future.py
@@ -45,7 +45,7 @@ class Future(object):
        self.is_done = True
        for f in self._errbacks:
            try:
-                f(e)
+                f(self.exception)
            except Exception:
                log.exception('Error processing errback')
        return self