diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-03-22 15:10:40 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-03-23 13:54:12 -0700 |
| commit | 4c87d11c26e2aa5a60de0b2213dd8caa3b16d553 (patch) | |
| tree | f03334bc6eba8adea3220dcf515ec8dfa564b5b4 | |
| parent | f18fd757e1d08172cd350bb278f01f26f19e5817 (diff) | |
| download | kafka-python-4c87d11c26e2aa5a60de0b2213dd8caa3b16d553.tar.gz | |
Heartbeat thread start / close
| -rw-r--r-- | kafka/coordinator/base.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/kafka/coordinator/base.py b/kafka/coordinator/base.py index 7d60234..b177567 100644 --- a/kafka/coordinator/base.py +++ b/kafka/coordinator/base.py @@ -910,11 +910,10 @@ class HeartbeatThread(threading.Thread): def run(self): try: + log.debug('Heartbeat thread started') while not self.closed: self._run_once() - log.debug('Heartbeat thread closed') - except ReferenceError: log.debug('Heartbeat thread closed due to coordinator gc') @@ -923,6 +922,9 @@ class HeartbeatThread(threading.Thread): self.coordinator.group_id, e) self.failed = e + finally: + log.debug('Heartbeat thread closed') + def _run_once(self): with self.coordinator._lock: if not self.enabled: |