Function emitChunk

apps/sim/lib/billing/cleanup-dispatcher.ts:219–226

(payload: CleanupJobPayload)

  let afterId: string | null = null

  const emitChunk = async (payload: CleanupJobPayload) => {
    if (payload.plan === housekeepingPlan && !housekeepingAssigned) {
      payload.runGlobalHousekeeping = true
      housekeepingAssigned = true
    }
    chunkCount++
    await onChunk(payload)
  }

  while (true) {
    const rows = await listActiveWorkspaceCleanupScopeRowsPage(afterId)