Function countRunningCells

apps/sim/lib/table/dispatcher.ts:230–263

(
  tableId: string,
  opts?: { includeUnclaimedPreStamps?: boolean }
)

 *
 *  Hits the `(table_id, status)` partial index on table_row_executions. */
export async function countRunningCells(
  tableId: string,
  opts?: { includeUnclaimedPreStamps?: boolean }
): Promise<{ total: number; byRowId: Record<string, number> }> {
  // `pending` + null-executionId rows are unclaimed pre-stamps. With an active
  // dispatch they're real queued work (include); with none they're abandoned
  // orphans that would pin the badge above zero forever (exclude).
  const excludeOrphanPreStamps = !opts?.includeUnclaimedPreStamps
  const rows = await db
    .select({
      rowId: tableRowExecutions.rowId,
      runningCount: sql<number>`count(*)::int`,
    })
    .from(tableRowExecutions)
    .where(
      and(
        eq(tableRowExecutions.tableId, tableId),
        inArray(tableRowExecutions.status, ['queued', 'running', 'pending']),
        excludeOrphanPreStamps
          ? or(ne(tableRowExecutions.status, 'pending'), isNotNull(tableRowExecutions.executionId))
          : undefined
      )
    )
    .groupBy(tableRowExecutions.rowId)
  let total = 0
  const byRowId: Record<string, number> = {}
  for (const r of rows) {
    if (r.runningCount > 0) {
      byRowId[r.rowId] = r.runningCount
      total += r.runningCount
    }
  }
  return { total, byRowId }
}

/** Authoritative "cells queued or running" count for the table, derived from
 *  active dispatches so it survives reload and matches the live count. For each