summaryrefslogtreecommitdiff
path: root/kafka/future.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/future.py')
-rw-r--r--kafka/future.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/future.py b/kafka/future.py
index c22755a..a4b7deb 100644
--- a/kafka/future.py
+++ b/kafka/future.py
@@ -55,7 +55,7 @@ class Future(object):
if args or kwargs:
f = functools.partial(f, *args, **kwargs)
if self.is_done and self.exception:
- self._call_backs('callback', [f], self.exception)
+ self._call_backs('errback', [f], self.exception)
else:
self._errbacks.append(f)
return self