diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-24 14:52:17 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-10-24 14:52:17 -0700 |
| commit | e485a5b996bd41d956a33563c1acf2fa76a4b3a9 (patch) | |
| tree | 2454ca36821e1ca0fe05a5fe7f073afc30cd6e53 | |
| parent | 53dd7989a05f7c0f6011f4e0f3a4ea1765c02b02 (diff) | |
| download | kafka-python-fast_lookup_coordinator_reset.tar.gz | |
Update commentfast_lookup_coordinator_reset
| -rw-r--r-- | kafka/coordinator/base.py | 5 |
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) |