fix: health check worker uses zcard instead of llen for arq sorted set queue

2026-07-19 02:25:42 +02:00
parent 4a43745b50
commit 6ed0752536
1 changed files with 1 additions and 1 deletions
@@ -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: