Method execute_step

core/src/tools/task.rs:564–610

(
        &self,
        spec: AgentStepSpec,
        event_tx: Option<broadcast::Sender<AgentEvent>>,
    )

#[async_trait]
impl AgentExecutor for TaskExecutor {
    async fn execute_step(
        &self,
        spec: AgentStepSpec,
        event_tx: Option<broadcast::Sender<AgentEvent>>,
    ) -> StepOutcome {
        let agent = spec.agent.clone();
        let task_id = spec.task_id.clone();
        let output_schema = spec.output_schema.clone();
        let params = TaskParams {
            agent: spec.agent,
            description: spec.description,
            prompt: spec.prompt,
            background: false,
            max_steps: spec.max_steps,
        };
        let mut outcome: StepOutcome = match self
            .execute_with_task_id(
                task_id.clone(),
                params,
                event_tx,
                spec.parent_session_id.as_deref(),
                true,
            )
            .await
        {
            Ok(result) => result.into(),
            Err(e) => return StepOutcome::failed(task_id, agent, format!("Task failed: {e}")),
        };

        // When the step requested structured output, coerce the (succeeded)
        // free-text result to the schema. A coercion failure demotes the step
        // to unsuccessful so callers never treat unvalidated text as the
        // promised object.
        if outcome.success {
            if let Some(schema) = output_schema {
                match self.coerce_to_schema(&outcome.output, schema).await {
                    Ok(object) => outcome.structured = Some(object),
                    Err(e) => {
                        outcome.success = false;
                        outcome.output =
                            format!("{}\n\n[structured output failed: {e}]", outcome.output);
                    }
                }
            }
        }
        outcome
    }

    fn concurrency_hint(&self) -> usize {
        self.max_parallel_tasks