Method handleTasksRunsStart

internal/extension/host_api_tasks.go:341–365

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleTasksRunsStart(ctx context.Context, raw json.RawMessage) (any, error) {
	var params hostAPITaskRunStartParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}
	runID := strings.TrimSpace(params.ID)
	if runID == "" {
		return nil, invalidParamsRPCError(errors.New("id is required"))
	}

	manager, actor, err := h.taskManagerAndActor(ctx)
	if err != nil {
		return nil, err
	}
	startReq, err := startTaskRunFromRequest(params.StartTaskRunRequest)
	if err != nil {
		return nil, err
	}

	run, err := manager.StartRun(ctx, runID, startReq, actor)
	if err != nil {
		return nil, mapTaskRPCError(runID, err)
	}
	return taskRunPayloadFromRun(run), nil
}

func (h *HostAPIHandler) handleTasksRunsAttachSession(ctx context.Context, raw json.RawMessage) (any, error) {
	var params hostAPITaskRunAttachSessionParams