diff options
Diffstat (limited to 'kafka/future.py')
| -rw-r--r-- | kafka/future.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/future.py b/kafka/future.py index 958e85f..06b8c3a 100644 --- 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 |