Function listActiveDispatches

apps/sim/lib/table/dispatcher.ts:310–335

(tableId: string)

}

export async function listActiveDispatches(tableId: string): Promise<DispatchRow[]> {
  const rows = await db
    .select()
    .from(tableRunDispatches)
    .where(
      and(
        eq(tableRunDispatches.tableId, tableId),
        inArray(tableRunDispatches.status, [...ACTIVE_DISPATCH_STATUSES])
      )
    )
  return rows.map((row) => ({
    id: row.id,
    tableId: row.tableId,
    workspaceId: row.workspaceId,
    requestId: row.requestId,
    mode: row.mode as DispatchMode,
    scope: row.scope as DispatchScope,
    status: row.status as DispatchStatus,
    cursor: row.cursor,
    limit: (row.limit as DispatchLimit | null) ?? null,
    processedCount: row.processedCount,
    isManualRun: row.isManualRun,
    triggeredByUserId: row.triggeredByUserId,
    requestedAt: row.requestedAt,
  }))
}

export async function readDispatch(dispatchId: string): Promise<DispatchRow | null> {
  const [row] = await db