diff --git a/app/core/monitoring.py b/app/core/monitoring.py
index 8bc69af..a6850a2 100644
--- a/app/core/monitoring.py
+++ b/app/core/monitoring.py
@@ -192,7 +192,7 @@ async def check_worker() -> dict[str, Any]:
         settings = get_settings()
         r = aioredis.from_url(settings.redis_url, decode_responses=True)
         # Check if arq queue key exists
-        queue_length = await r.llen("arq:queue")
+        queue_length = await r.zcard("arq:queue")
         await r.aclose()
         return {"status": "up", "queue_length": queue_length}
     except Exception as e: