feat(backend): reduce RQ worker registry sweep verbosity and frequency

Generated-By: PostHog Code

Author: gantoine

backend/handler/rq_worker.py

@@ -0,0 +1,25 @@
+import logging
+from typing import Any
+
+from rq import Worker
+
+
+class _DropRegistryCleanupFilter(logging.Filter):
+    """Drops RQ's periodic "cleaning registries for queue" INFO line.
+
+    The maintenance sweep still runs (crash recovery for orphaned jobs, TTL
+    reaping, stale worker pruning); only its log record is suppressed so it
+    does not flood logs on every maintenance interval.
+    """
+
+    def filter(self, record: logging.LogRecord) -> bool:
+        return "cleaning registries for queue" not in record.getMessage()
+
+
+class RomMWorker(Worker):
+    """RQ worker that silences the noisy registry-cleanup log line."""
+
+    def __init__(self, *args: Any, **kwargs: Any) -> None:
+        super().__init__(*args, **kwargs)
+        if not any(isinstance(f, _DropRegistryCleanupFilter) for f in self.log.filters):
+            self.log.addFilter(_DropRegistryCleanupFilter())

docker/init_scripts/init

@@ -233,8 +233,12 @@ start_bin_rq_worker() {
 	fi
 
 	# Set PYTHONPATH so RQ can find the tasks module
+	# Sweep registries hourly instead of every ~10 min, using a worker class that
+	# drops the noisy per-sweep "cleaning registries for queue" log line.
 	PYTHONPATH="/backend:${PYTHONPATH-}" rq worker \
 		--path /backend \
+		--worker-class handler.rq_worker.RomMWorker \
+		--maintenance-interval 3600 \
 		--pid /tmp/rq_worker.pid \
 		--url "${redis_url}" \
 		--results-ttl "${TASK_RESULT_TTL:-86400}" \

entrypoint.sh

@@ -69,8 +69,12 @@ else
 fi
 
 # Set PYTHONPATH so RQ can find the tasks module
+# Sweep registries hourly instead of every ~10 min, using a worker class that
+# drops the noisy per-sweep "cleaning registries for queue" log line.
 PYTHONPATH="/app/backend:${PYTHONPATH-}" rq worker \
 	--path /app/backend \
+	--worker-class handler.rq_worker.RomMWorker \
+	--maintenance-interval 3600 \
 	--pid /tmp/rq_worker.pid \
 	--url "${REDIS_URL}" \
 	--logging_level "${LOGLEVEL:-INFO}" \