Start the background renewal thread.
(self)
| 363 | logger.error(f"Error renewing lock {self.lock_id}: {e}") |
| 364 | |
| 365 | def start(self): |
| 366 | """Start the background renewal thread.""" |
| 367 | self._stop_event.clear() |
| 368 | self._thread = threading.Thread( |
| 369 | target=self._renew_loop, daemon=True, |
| 370 | name=f"lock-renew-{self.task_name}-{self.id}" |
| 371 | ) |
| 372 | self._thread.start() |
| 373 | return self |
| 374 | |
| 375 | def stop(self): |
| 376 | """Stop the renewal thread.""" |
no outgoing calls
no test coverage detected