Function cancelAutonomyFlowText

src/cli/handlers/autonomy.ts:125–162

(
  flowId: string,
  options?: {
    removeQueuedInMemory?: boolean
    rootDir?: string
  },
)

}

export async function cancelAutonomyFlowText(
  flowId: string,
  options?: {
    removeQueuedInMemory?: boolean
    rootDir?: string
  },
): Promise<string> {
  const cancelled = await requestManagedAutonomyFlowCancel({
    flowId,
    rootDir: options?.rootDir,
  })
  if (!cancelled) {
    return 'Autonomy flow not found.'
  }
  if (!cancelled.accepted) {
    return `Autonomy flow ${flowId} is already terminal (${cancelled.flow.status}).`
  }

  let removedCount = 0
  if (options?.removeQueuedInMemory) {
    const removed = removeByFilter(cmd => cmd.autonomy?.flowId === flowId)
    removedCount = removed.length
    for (const command of removed) {
      if (command.autonomy?.runId) {
        await markAutonomyRunCancelled(command.autonomy.runId, options?.rootDir)
      }
    }
  } else {
    for (const runId of cancelled.queuedRunIds) {
      await markAutonomyRunCancelled(runId, options?.rootDir)
    }
    removedCount = cancelled.queuedRunIds.length
  }

  return cancelled.flow.status === 'running'
    ? `Cancellation requested for flow ${flowId}. The current step is still running, and no new steps will be started.`
    : `Cancelled flow ${flowId}. Removed ${removedCount} queued step(s).`
}

export async function autonomyFlowCancelHandler(flowId: string): Promise<void> {
  process.stdout.write(`${await cancelAutonomyFlowText(flowId)}\n`)