Function fail_agent_task

src/tasks/local_agent.py:294–315

Flip status to ``failed``, record error, schedule eviction.

(
    task_id: str,
    *,
    error: str,
    registry: "RuntimeTaskRegistry",
)

def fail_agent_task(
    task_id: str,
    *,
    error: str,
    registry: "RuntimeTaskRegistry",
) -> None:
    """Flip status to ``failed``, record error, schedule eviction."""
    def _fail(prev: TaskStateBase) -> TaskStateBase:
        if not isinstance(prev, LocalAgentTaskState):
            return prev
        if is_terminal_task_status(prev.status):
            return prev
        # Mirror error into result_text so TaskOutput callers reading
        # the final text still see something useful (TS does this).
        return _terminal_replace(
            prev,
            status="failed",
            error=error,
            result_text=prev.result_text or error,
        )

    registry.update(task_id, _fail)


def kill_async_agent(