From 7c5cdff3026bee32f1c25b270bd1d5acc3d26bf9 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 28 Sep 2019 14:45:27 -0700 Subject: [PATCH] Return float(inf) seconds instead of sys.maxsize int in coordinator time to next poll() --- kafka/coordinator/base.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 421360eab..5cdbdcfea 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -321,10 +321,14 @@ def poll_heartbeat(self): self.heartbeat.poll() def time_to_next_heartbeat(self): + """Returns seconds (float) remaining before next heartbeat should be sent + + Note: Returns infinite if group is not joined + """ with self._lock: # if we have not joined the group, we don't need to send heartbeats if self.state is MemberState.UNJOINED: - return sys.maxsize + return float('inf') return self.heartbeat.time_to_next_heartbeat() def _handle_join_success(self, member_assignment_bytes):