Function normalizeForceFailRun

internal/task/force_ops.go:558–576

(req ForceFailRun)

}

func normalizeForceFailRun(req ForceFailRun) (ForceFailRun, error) {
	req.Reason = strings.TrimSpace(req.Reason)
	if req.Reason == "" {
		return ForceFailRun{}, forceRunDiagnosticError(
			diagnosticcontract.CodeForceOpRequiresReason,
			"Force fail requires a reason",
			"Provide --reason so the recovery audit event explains why the run was failed.",
			diagnosticcontract.SeverityError,
			"agh task fail <run-id> --reason \"operator recovery\"",
			nil,
			ErrForceOpRequiresReason,
		)
	}
	req.Metadata = normalizeRawJSON(req.Metadata)
	if err := ValidateMetadataSize(req.Metadata, "force_fail.metadata"); err != nil {
		return ForceFailRun{}, err
	}
	return req, nil
}

func normalizeRetryRunRequest(req RetryRunRequest) (RetryRunRequest, error) {
	req.Metadata = normalizeRawJSON(req.Metadata)