diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-09-28 14:45:27 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-09-28 16:33:01 -0700 |
| commit | 615c57b57e71e0cf4c53b14dcef1cd27f1b97d86 (patch) | |
| tree | 388fe3423b427a325bafea3fb1d67076c3bde3cb | |
| parent | 9248b7bb14e72d81a3f29e54bd0719bc27e20d2c (diff) | |
| download | kafka-python-consumer_iterator_with_poll.tar.gz | |
Return float(inf) seconds instead of sys.maxsize int in coordinator time to next poll()consumer_iterator_with_poll
| -rw-r--r-- | kafka/coordinator/base.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 421360e..5cdbdcf 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -321,10 +321,14 @@ class BaseCoordinator(object): 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): |