Function cleanupRunChildren

apps/sim/background/cleanup-tasks.ts:41–67

(
  workspaceIds: string[],
  retentionDate: Date,
  label: string
)

] as const

async function cleanupRunChildren(
  workspaceIds: string[],
  retentionDate: Date,
  label: string
): Promise<TableCleanupResult[]> {
  if (workspaceIds.length === 0) return []

  const runIds = await selectRowsByIdChunks(workspaceIds, (chunkIds, chunkLimit) =>
    db
      .select({ id: copilotRuns.id })
      .from(copilotRuns)
      .where(
        and(inArray(copilotRuns.workspaceId, chunkIds), lt(copilotRuns.updatedAt, retentionDate))
      )
      .limit(chunkLimit)
  )

  if (runIds.length === 0) {
    return RUN_CHILD_TABLES.map((t) => ({ table: `${label}/${t.name}`, deleted: 0, failed: 0 }))
  }

  const ids = runIds.map((r) => r.id)

  return Promise.all(
    RUN_CHILD_TABLES.map((t) => deleteRowsById(t.table, t.runIdCol, ids, `${label}/${t.name}`))
  )
}

export async function runCleanupTasks(payload: CleanupJobPayload): Promise<void> {
  const startTime = Date.now()