Function killInProcessTeammate

src/utils/swarm/spawnInProcess.ts:228–351

(
  taskId: string,
  setAppState: SetAppStateFn,
)

 * @returns true if killed successfully
 */
export function killInProcessTeammate(
  taskId: string,
  setAppState: SetAppStateFn,
): boolean {
  let killed = false
  let teamName: string | null = null
  let agentId: string | null = null
  let toolUseId: string | undefined
  let description: string | undefined
  let pendingAutonomyRuns: Array<{ runId: string; rootDir?: string }> = []

  setAppState((prev: AppState) => {
    const task = prev.tasks[taskId]
    if (!task || task.type !== 'in_process_teammate') {
      return prev
    }

    const teammateTask = task as InProcessTeammateTaskState

    if (teammateTask.status !== 'running') {
      return prev
    }

    // Capture identity for cleanup after state update
    teamName = teammateTask.identity.teamName
    agentId = teammateTask.identity.agentId
    toolUseId = teammateTask.toolUseId
    description = teammateTask.description

    // Capture pending autonomy run IDs before clearing them
    pendingAutonomyRuns = teammateTask.pendingUserMessages.flatMap(message =>
      message.autonomyRunId
        ? [
            {
              runId: message.autonomyRunId,
              ...(message.autonomyRootDir
                ? { rootDir: message.autonomyRootDir }
                : {}),
            },
          ]
        : [],
    )

    // Abort the controller to stop execution
    teammateTask.abortController?.abort()

    // Call cleanup handler
    teammateTask.unregisterCleanup?.()

    // Update task state and remove from teamContext.teammates
    killed = true

    // Call pending idle callbacks to unblock any waiters (e.g., engine.waitForIdle)
    teammateTask.onIdleCallbacks?.forEach(cb => cb())

    // Remove from teamContext.teammates using the agentId
    let updatedTeamContext = prev.teamContext
    if (prev.teamContext && prev.teamContext.teammates && agentId) {