Function killWorkflowTask

src/tasks/LocalWorkflowTask/LocalWorkflowTask.tsx:438–480

(
  taskId: string,
  setAppState: SetAppState,
)

}

export async function killWorkflowTask(
  taskId: string,
  setAppState: SetAppState,
): Promise<void> {
  let shouldNotify = false

  updateWorkflowTask(taskId, setAppState, task => {
    if (task.status !== 'running') {
      return task
    }

    shouldNotify = true
    task.abortController?.abort()
    for (const controller of Object.values(task.agentControllers ?? {})) {
      controller.abort()
    }

    const agents = task.agents.map(agent =>
      agent.status === 'completed' || agent.status === 'failed'
        ? agent
        : {
            ...agent,
            status: 'killed',
            endTime: agent.endTime ?? Date.now(),
          },
    )

    return {
      ...task,
      ...countAgents(agents),
      status: 'killed',
      endTime: Date.now(),
      agents,
      abortController: undefined,
      agentControllers: {},
    }
  })

  if (shouldNotify) {
    enqueueWorkflowNotification(taskId, setAppState, 'killed')
    void evictTaskOutput(taskId)
  }
}

export async function skipWorkflowAgent(
  taskId: string,