Function runWorkflowLifecycle

src/tools/WorkflowTool/WorkflowTool.ts:374–475

({
  taskId,
  workflowName,
  objective,
  executionMode,
  agents,
  workflowAbortController,
  toolUseContext,
  canUseTool,
  parentMessage,
  rootSetAppState,
}: WorkflowRuntimeParams)

}

async function runWorkflowLifecycle({
  taskId,
  workflowName,
  objective,
  executionMode,
  agents,
  workflowAbortController,
  toolUseContext,
  canUseTool,
  parentMessage,
  rootSetAppState,
}: WorkflowRuntimeParams): Promise<void> {
  appendWorkflowLog(
    taskId,
    `Workflow ${workflowName} started with ${agents.length} agent${agents.length === 1 ? '' : 's'} (${executionMode}).`,
  )
  appendWorkflowLog(taskId, `Objective: ${objective}`)

  try {
    const results: Array<'completed' | 'failed' | 'killed'> = []

    if (executionMode === 'parallel') {
      results.push(
        ...(await Promise.all(
          agents.map(agent =>
            runWorkflowAgentTask({
              taskId,
              executionMode,
              agent,
              workflowAbortController,
              toolUseContext,
              canUseTool,
              parentMessage,
              rootSetAppState,
            }),
          ),
        )),
      )
    } else {
      for (const agent of agents) {
        if (workflowAbortController.signal.aborted) {
          results.push('killed')
          break
        }

        const result = await runWorkflowAgentTask({
          taskId,
          executionMode,
          agent,
          workflowAbortController,
          toolUseContext,
          canUseTool,
          parentMessage,
          rootSetAppState,
        })
        results.push(result)

        if (result === 'failed') {