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 e5025c8 commit 1a1cc04Copy full SHA for 1a1cc04
kafka/coordinator/base.py
@@ -923,15 +923,16 @@ def close(self):
923
if self.closed:
924
return
925
self.closed = True
926
- with self.coordinator._lock:
927
- self.coordinator._lock.notify()
928
929
# Generally this should not happen - close() is triggered
930
# by the coordinator. But in some cases GC may close the coordinator
931
# from within the heartbeat thread.
932
if threading.current_thread() == self:
933
934
+ with self.coordinator._lock:
+ self.coordinator._lock.notify()
935
+
936
if self.is_alive():
937
self.join(self.coordinator.config['heartbeat_interval_ms'] / 1000)
938
0 commit comments