Function waitForQueueToEmpty

apps/worker/src/boot-workers.ts:410–434

(queue: Queue, timeout = 60_000)

}

export async function waitForQueueToEmpty(queue: Queue, timeout = 60_000) {
  const startTime = performance.now();

  while (true) {
    const activeCount = await queue.getActiveCount();

    if (activeCount === 0) {
      break;
    }

    if (performance.now() - startTime > timeout) {
      logger.warn(
        { queue: queue.name, remainingCount: activeCount },
        'Timeout reached while waiting for queue to empty'
      );
      break;
    }

    logger.info(
      { queue: queue.name, count: activeCount },
      'Waiting for queue to finish'
    );
    await sleep(500);
  }
}