Method CompleteTaskRun

internal/api/core/tasks.go:1630–1671

CompleteTaskRun marks one running run as completed.

(c *gin.Context)

// CompleteTaskRun marks one running run as completed.
func (h *BaseHandlers) CompleteTaskRun(c *gin.Context) {
	manager, ok := h.requireTaskManager(c)
	if !ok {
		return
	}

	runID, err := requiredPathID(c.Param("id"), "run id")
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	var req contract.CompleteTaskRunRequest
	if err := decodeOptionalJSON(c, &req); err != nil {
		h.respondError(
			c,
			http.StatusBadRequest,
			NewTaskValidationError(fmt.Errorf("%s: decode complete run request: %w", h.transportName(), err)),
		)
		return
	}

	actor, err := h.taskActorContext(c, taskActionCompleteRun)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	result, err := completeTaskRunFromRequest(req)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	run, err := manager.CompleteRun(c.Request.Context(), runID, result, actor)
	if err != nil {
		h.respondError(c, StatusForTaskError(err), err)
		return
	}

	c.JSON(http.StatusOK, contract.TaskRunResponse{Run: TaskRunPayloadFromRun(run)})
}

// FailTaskRun marks one run as failed.
func (h *BaseHandlers) FailTaskRun(c *gin.Context) {