summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2017-10-24 14:52:17 -0700
committerDana Powers <dana.powers@gmail.com>2017-10-24 14:52:17 -0700
commite485a5b996bd41d956a33563c1acf2fa76a4b3a9 (patch)
tree2454ca36821e1ca0fe05a5fe7f073afc30cd6e53
parent53dd7989a05f7c0f6011f4e0f3a4ea1765c02b02 (diff)
downloadkafka-python-e485a5b996bd41d956a33563c1acf2fa76a4b3a9.tar.gz
-rw-r--r--kafka/coordinator/base.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py
index 6e07211..a3055da 100644
--- a/kafka/coordinator/base.py
+++ b/kafka/coordinator/base.py
@@ -232,8 +232,9 @@ class BaseCoordinator(object):
return self._find_coordinator_future
# If there is an error sending the group coordinator request
- # then the errback will immediately fire and reset _find_coordinator_future = None
- # To avoid the race, we capture the future in a local variable and return it
+ # then _reset_find_coordinator_future will immediately fire and
+ # set _find_coordinator_future = None
+ # To avoid returning None, we capture the future in a local variable
self._find_coordinator_future = self._send_group_coordinator_request()
future = self._find_coordinator_future
self._find_coordinator_future.add_both(self._reset_find_coordinator_future)