Function loadExecutionsByRow

apps/sim/lib/table/rows/executions.ts:26–71

(
  trx: DbOrTx,
  rowIds: Iterable<string>
)

 * `Map<rowId, RowExecutions>` suitable for plugging into `TableRow.executions`.
 */
export async function loadExecutionsByRow(
  trx: DbOrTx,
  rowIds: Iterable<string>
): Promise<Map<string, RowExecutions>> {
  const ids = Array.from(new Set(rowIds))
  const result = new Map<string, RowExecutions>()
  if (ids.length === 0) return result
  // Explicit column list, never `select()` — `enrichmentDetails` is large and
  // must stay off the hot grid read path (fetched on demand via
  // `loadEnrichmentDetail`).
  const rows = await trx
    .select({
      rowId: tableRowExecutions.rowId,
      groupId: tableRowExecutions.groupId,
      status: tableRowExecutions.status,
      executionId: tableRowExecutions.executionId,
      jobId: tableRowExecutions.jobId,
      workflowId: tableRowExecutions.workflowId,
      error: tableRowExecutions.error,
      runningBlockIds: tableRowExecutions.runningBlockIds,
      blockErrors: tableRowExecutions.blockErrors,
      cancelledAt: tableRowExecutions.cancelledAt,
    })
    .from(tableRowExecutions)
    .where(inArray(tableRowExecutions.rowId, ids))
  for (const r of rows) {
    const existing = result.get(r.rowId) ?? {}
    const meta: RowExecutionMetadata = {
      status: r.status as RowExecutionMetadata['status'],
      executionId: r.executionId ?? null,
      jobId: r.jobId ?? null,
      workflowId: r.workflowId,
      error: r.error ?? null,
      ...(r.runningBlockIds && r.runningBlockIds.length > 0
        ? { runningBlockIds: r.runningBlockIds }
        : {}),
      ...(r.blockErrors && Object.keys(r.blockErrors as Record<string, string>).length > 0
        ? { blockErrors: r.blockErrors as Record<string, string> }
        : {}),
      ...(r.cancelledAt ? { cancelledAt: r.cancelledAt.toISOString() } : {}),
    }
    existing[r.groupId] = meta
    result.set(r.rowId, existing)
  }
  return result
}

/** Convenience: load executions for one row, returning `{}` when missing. */
export async function loadExecutionsForRow(trx: DbOrTx, rowId: string): Promise<RowExecutions> {