diff options
| -rw-r--r-- | kafka/future.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/future.py b/kafka/future.py index a4b7deb..4a3af47 100644 --- a/kafka/future.py +++ b/kafka/future.py @@ -30,7 +30,8 @@ class Future(object): assert not self.is_done, 'Future is already complete' self.value = value self.is_done = True - self._call_backs('callback', self._callbacks, self.value) + if self._callbacks: + self._call_backs('callback', self._callbacks, self.value) return self def failure(self, e): |