Function inspectQueue

packages/db/scripts/check-sessions.ts:113–125

()

}

async function inspectQueue() {
  const [waiting, delayed, active, failed, completed] = await Promise.all([
    sessionsQueue.getWaitingCount(),
    sessionsQueue.getDelayedCount(),
    sessionsQueue.getActiveCount(),
    sessionsQueue.getFailedCount(),
    sessionsQueue.getCompletedCount(),
  ]);

  const failedSample = failed > 0 ? await sessionsQueue.getFailed(0, 4) : [];

  return { waiting, delayed, active, failed, completed, failedSample };
}

async function inspectBuffers() {
  const redis = getRedisCache();