diff --git a/apps/worker/app/core/visibility_recovery_watchdog.py b/apps/worker/app/core/visibility_recovery_watchdog.py index 0d2d3cd5b..fa3b3febc 100644 --- a/apps/worker/app/core/visibility_recovery_watchdog.py +++ b/apps/worker/app/core/visibility_recovery_watchdog.py @@ -46,9 +46,10 @@ def run_visibility_recovery_watchdog() -> None: while True: try: result: VisibilityRecoveryResult = restore_expired_reservations() - logger.bind(**result).info( - "Expired Celery reservation recovery sweep attempted" - ) + if result["status"] == "attempted": + logger.bind(**result).debug( + "Expired Celery reservation recovery sweep attempted" + ) except Exception: logger.exception("Expired Celery reservation recovery sweep failed") finally: diff --git a/packages/shared-python/shared/services/redis/periodic_task_lock.py b/packages/shared-python/shared/services/redis/periodic_task_lock.py index 47859cb14..3d07d38d8 100644 --- a/packages/shared-python/shared/services/redis/periodic_task_lock.py +++ b/packages/shared-python/shared/services/redis/periodic_task_lock.py @@ -105,7 +105,7 @@ def periodic_task_lock( if acquired: logger.debug(f"periodic_task_lock: acquired for task='{task_name}', ttl={ttl}s") else: - logger.info( + logger.debug( f"periodic_task_lock: task='{task_name}' already running in this " "window (duplicate Beat firing) — skipping" )