We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e039108 commit a709cc5Copy full SHA for a709cc5
kafka/coordinator/base.py
@@ -919,7 +919,7 @@ def _run_once(self):
919
self.coordinator._client.poll(timeout_ms=0)
920
921
if self.coordinator.coordinator_unknown():
922
- if not self.coordinator.lookup_coordinator().is_done():
+ if not self.coordinator.lookup_coordinator().is_done:
923
self.coordinator._lock.wait(self.coordinator.config['retry_backoff_ms'] / 1000)
924
925
elif self.coordinator.heartbeat.session_timeout_expired():
0 commit comments