Method nativeTaskLeaseActor

internal/daemon/native_tools.go:4486–4517

(
	ctx context.Context,
	id toolspkg.ToolID,
	scope toolspkg.Scope,
	taskID string,
	runID string,
)

}

func (n *daemonNativeTools) nativeTaskLeaseActor(
	ctx context.Context,
	id toolspkg.ToolID,
	scope toolspkg.Scope,
	taskID string,
	runID string,
) (taskpkg.ActorContext, taskpkg.AutonomyLeaseHandle, error) {
	actor, sessionID, err := autonomyActorContext(id, scope)
	if err != nil {
		return taskpkg.ActorContext{}, taskpkg.AutonomyLeaseHandle{}, err
	}
	normalizedTaskID, err := requiredNativeString(id, "task_id", taskID)
	if err != nil {
		return taskpkg.ActorContext{}, taskpkg.AutonomyLeaseHandle{}, err
	}
	normalizedRunID, err := requiredNativeString(id, "run_id", runID)
	if err != nil {
		return taskpkg.ActorContext{}, taskpkg.AutonomyLeaseHandle{}, err
	}
	handle, err := n.lookupAutonomyLease(ctx, id, sessionID, normalizedRunID)
	if err != nil {
		return taskpkg.ActorContext{}, taskpkg.AutonomyLeaseHandle{}, err
	}
	if strings.TrimSpace(handle.TaskID) != normalizedTaskID {
		return taskpkg.ActorContext{}, taskpkg.AutonomyLeaseHandle{}, nativeAutonomyForeignRunTaskError(
			id,
			normalizedTaskID,
			normalizedRunID,
		)
	}
	return actor, handle, nil
}

func nativeTaskBlockExpiresAt(expiresAt *time.Time) time.Time {
	if expiresAt == nil {