Function showStatus

scripts/pipeline/batch-processor.ts:648–711

()

}

async function showStatus(): Promise<void> {
  console.log("\n=== Batch Processor Status ===\n");

  // Job queue stats
  const jobStats = await db
    .select({
      status: pipelineJobs.status,
      count: sql<number>`COUNT(*)::int`,
    })
    .from(pipelineJobs)
    .where(eq(pipelineJobs.jobType, "ai_analysis"))
    .groupBy(pipelineJobs.status);

  console.log("Pipeline Jobs:");
  for (const stat of jobStats) {
    console.log(`  ${stat.status}: ${stat.count}`);
  }
  if (jobStats.length === 0) console.log("  (none)");

  // Document analysis stats
  const docStats = await db
    .select({
      status: documents.aiAnalysisStatus,
      count: sql<number>`COUNT(*)::int`,
    })
    .from(documents)
    .groupBy(documents.aiAnalysisStatus);

  console.log("\nDocument Analysis Status:");
  for (const stat of docStats) {
    console.log(`  ${stat.status ?? "null"}: ${stat.count}`);
  }

  // Budget
  const { totalCents, docCount } = await getMonthlySpend();
  console.log(`\nMonthly Spend: ${formatCents(totalCents)} across ${docCount} documents`);

  // Top priority pending
  const topJobs = await db
    .select({
      priority: pipelineJobs.priority,
      count: sql<number>`COUNT(*)::int`,
    })
    .from(pipelineJobs)
    .where(
      and(
        eq(pipelineJobs.jobType, "ai_analysis"),
        eq(pipelineJobs.status, "pending"),
      )
    )
    .groupBy(pipelineJobs.priority)
    .orderBy(desc(pipelineJobs.priority))
    .limit(5);

  if (topJobs.length > 0) {
    console.log("\nPending by Priority:");
    for (const j of topJobs) {
      const dsName = Object.entries(DATASET_PRIORITY).find(([_, v]) => v === j.priority)?.[0];