diff options
| -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) |