Function dispatchCleanupJobs

apps/sim/lib/billing/cleanup-dispatcher.ts:297–380

(jobType: CleanupJobType)

 * Falls back to `JobQueueBackend` enqueue when Trigger.dev isn't available.
 */
export async function dispatchCleanupJobs(jobType: CleanupJobType): Promise<{
  jobIds: string[]
  jobCount: number
  chunkCount: number
  workspaceCount: number
}> {
  const jobIds: string[] = []
  let succeeded = 0
  let failed = 0

  if (isTriggerAvailable()) {
    let batch: CleanupJobPayload[] = []
    const flushBatch = async () => {
      if (batch.length === 0) return
      const currentBatch = batch
      batch = []
      const region = await resolveTriggerRegion()
      const batchResult = await tasks.batchTrigger(
        jobType,
        currentBatch.map((payload) => ({
          payload,
          options: {
            tags: [`plan:${payload.plan}`, `jobType:${jobType}`],
            concurrencyKey: getCleanupConcurrencyKey(jobType),
            region,
          },
        }))
      )
      jobIds.push(batchResult.batchId)
      succeeded += currentBatch.length
    }

    const { chunkCount, workspaceCount } = await forEachCleanupChunk(jobType, async (payload) => {
      batch.push(payload)
      if (batch.length >= BATCH_TRIGGER_CHUNK_SIZE) {
        await flushBatch()
      }
    })
    await flushBatch()

    logger.info(
      `[${jobType}] Trigger cleanup chunks: ${succeeded} dispatched in ${jobIds.length} batch(es)`
    )
    return { jobIds, jobCount: jobIds.length, chunkCount, workspaceCount }
  }

  const inlineRunner = shouldExecuteInline() ? await buildCleanupRunner(jobType) : undefined
  if (inlineRunner) {
    const { chunkCount, workspaceCount } = await forEachCleanupChunk(jobType, async (payload) => {
      try {
        await inlineRunner(payload, new AbortController().signal)
        jobIds.push(`inline:${jobType}:${payload.label}`)
        succeeded++
      } catch (error) {
        failed++
        logger.error(`[${jobType}] Inline cleanup chunk failed:`, {
          plan: payload.plan,
          label: payload.label,