Method autonomyFail

internal/daemon/native_tools.go:3455–3493

(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
)

}

func (n *daemonNativeTools) autonomyFail(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input autonomyFailInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	actor, sessionID, err := autonomyActorContext(req.ToolID, scope)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	runID, err := requiredNativeString(req.ToolID, "run_id", input.RunID)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	failure := taskpkg.RunFailure{
		Error:    strings.TrimSpace(input.Error),
		Metadata: cloneJSON(input.Metadata),
	}
	if err := failure.Validate("run_failure"); err != nil {
		return toolspkg.ToolResult{}, nativeAutonomyToolError(req.ToolID, err)
	}
	handle, err := n.lookupAutonomyLease(ctx, req.ToolID, sessionID, runID)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	run, err := n.deps.Tasks.FailRunLease(ctx, taskpkg.LeaseFailure{
		RunID:      runID,
		ClaimToken: handle.ClaimToken,
		Failure:    failure,
	}, actor)
	if err != nil {
		return toolspkg.ToolResult{}, nativeAutonomyToolError(req.ToolID, err)
	}
	lease := core.AgentTaskLeasePayloadFromRun(run, nil)
	return structuredResult(map[string]any{nativeToolsLeaseKey: lease}, fmt.Sprintf("failed %s", lease.RunID))
}

func (n *daemonNativeTools) autonomyRelease(
	ctx context.Context,