Function processQueue

apps/worker/src/process-queue.tsx:193–219

* Main queue processing loop

()

 * Main queue processing loop
 */
async function processQueue() {
  const BATCH_SIZE = Number.parseInt(process.env.UPDATE_BATCH_SIZE || "100");

  console.log(`[Queue] Starting with batch size ${BATCH_SIZE}`);

  while (!isShuttingDown) {
    try {
      const jobs = await dequeueJobs(BATCH_SIZE);

      if (jobs.length > 0) {
        await processBatch(jobs);
      } else {
        await handleIdleQueue(BATCH_SIZE);
      }

      // Wait before next poll
      await new Promise((resolve) =>
        setTimeout(resolve, QUEUE_POLL_INTERVAL_MS)
      );
    } catch (error) {
      console.error("[Queue] Unexpected error in main loop:", error);
      // Continue processing despite errors in individual iterations
    }
  }

  console.log("[Queue] Shutdown complete");
}

if (import.meta.url === `file://${process.argv[1]}`) {
  processQueue().catch((error) => {