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 2f713cf commit 2997a57Copy full SHA for 2997a57
kafka/coordinator/base.py
@@ -321,10 +321,14 @@ def poll_heartbeat(self):
321
self.heartbeat.poll()
322
323
def time_to_next_heartbeat(self):
324
+ """Returns seconds (float) remaining before next heartbeat should be sent
325
+
326
+ Note: Returns infinite if group is not joined
327
+ """
328
with self._lock:
329
# if we have not joined the group, we don't need to send heartbeats
330
if self.state is MemberState.UNJOINED:
- return sys.maxsize
331
+ return float('inf')
332
return self.heartbeat.time_to_next_heartbeat()
333
334
def _handle_join_success(self, member_assignment_bytes):
0 commit comments