diff --git a/ergo_celery/request/request.py b/ergo_celery/request/request.py index 03d31a1..8b477c4 100644 --- a/ergo_celery/request/request.py +++ b/ergo_celery/request/request.py @@ -55,3 +55,5 @@ def ping_message(self, worker): ) finally: self._lock.release() + else: + logger.info(f'Task "{self.humaninfo()}" locking failed during periodic ping')