Method autonomyComplete

internal/daemon/native_tools.go:3417–3453

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

}

func (n *daemonNativeTools) autonomyComplete(
	ctx context.Context,
	scope toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input autonomyCompleteInput
	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
	}
	result := taskpkg.RunResult{Value: cloneJSON(input.Result)}
	if err := result.Validate("run_result"); 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.CompleteRunLease(ctx, taskpkg.LeaseCompletion{
		RunID:          runID,
		ClaimToken:     handle.ClaimToken,
		Result:         result,
		CreatedTaskIDs: trimNativeStrings(input.CreatedTaskIDs),
	}, 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("completed %s", lease.RunID))
}

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