Function markActiveDispatchesCancelled

apps/sim/lib/table/dispatcher.ts:756–813

(
  tableId: string,
  scopeFilter?: Filter,
  spareExcludedRowIds?: string[]
)

 *  (select-all-minus-deselections Stop) to spare row-scoped dispatches whose
 *  rows are ALL deselected — that work wasn't in the stopped selection. */
export async function markActiveDispatchesCancelled(
  tableId: string,
  scopeFilter?: Filter,
  spareExcludedRowIds?: string[]
): Promise<DispatchRow[]> {
  const cancelled = await db
    .update(tableRunDispatches)
    .set({ status: 'cancelled', cancelledAt: new Date() })
    .where(
      and(
        eq(tableRunDispatches.tableId, tableId),
        inArray(tableRunDispatches.status, [...ACTIVE_DISPATCH_STATUSES]),
        scopeFilter
          ? sql`${tableRunDispatches.scope}->'filter' = ${JSON.stringify(scopeFilter)}::jsonb`
          : undefined,
        // coalesce(false): table-wide dispatches have no scope.rowIds (NULL <@ x
        // is NULL) and must still cancel.
        spareExcludedRowIds && spareExcludedRowIds.length > 0
          ? sql`NOT coalesce(
              ${tableRunDispatches.scope}->'rowIds' <@ ${JSON.stringify(spareExcludedRowIds)}::jsonb
                AND jsonb_array_length(${tableRunDispatches.scope}->'rowIds') > 0,
              false
            )`
          : undefined
      )
    )
    .returning()
  const dispatches = cancelled.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: 'cancelled' as DispatchStatus,
    cursor: row.cursor,
    limit: (row.limit as DispatchLimit | null) ?? null,
    processedCount: row.processedCount,
    isManualRun: row.isManualRun,
    triggeredByUserId: row.triggeredByUserId,
    requestedAt: row.requestedAt,
  }))
  await Promise.all(
    dispatches.map((d) =>
      appendTableEvent({
        kind: 'dispatch',
        tableId: d.tableId,
        dispatchId: d.id,
        status: 'cancelled',
        scope: d.scope,
        cursor: d.cursor,
        mode: d.mode,
        isManualRun: d.isManualRun,
      })
    )
  )
  return dispatches
}