Method AgentTaskFail

internal/api/core/agent_tasks.go:262–299

AgentTaskFail fails one claimed task run after token verification.

(c *gin.Context)

// AgentTaskFail fails one claimed task run after token verification.
func (h *BaseHandlers) AgentTaskFail(c *gin.Context) {
	manager, caller, runID, ok := h.agentTaskLeaseMutationSetup(c, agentTaskActionFail)
	if !ok {
		return
	}

	var req contract.AgentTaskFailRequest
	if err := c.ShouldBindJSON(&req); err != nil {
		h.respondError(
			c,
			http.StatusBadRequest,
			NewTaskValidationError(fmt.Errorf("%s: decode agent task fail request: %w", h.transportName(), err)),
		)
		return
	}

	failure, err := failTaskRunFromRequest(contract.FailTaskRunRequest(req))
	if err != nil {
		h.respondError(c, statusForAgentTaskError(err), err)
		return
	}
	handle, err := h.lookupAgentTaskLease(c.Request.Context(), manager, caller, runID)
	if err != nil {
		h.respondError(c, statusForAgentTaskError(err), err)
		return
	}
	run, err := manager.FailRunLease(c.Request.Context(), taskpkg.LeaseFailure{
		RunID:      runID,
		ClaimToken: handle.ClaimToken,
		Failure:    failure,
	}, caller.Actor)
	if err != nil {
		h.respondError(c, statusForAgentTaskError(err), err)
		return
	}

	c.JSON(http.StatusOK, contract.AgentTaskLeaseResponse{Lease: AgentTaskLeasePayloadFromRun(run, nil)})
}

func (h *BaseHandlers) agentTaskLeaseMutationSetup(
	c *gin.Context,