Function validateTaskRunReviewGateFields

internal/task/validate.go:577–624

(r Run)

}

func validateTaskRunReviewGateFields(r Run) error {
	if r.Review == nil {
		return nil
	}
	lineage := *r.Review
	if lineage.RequestRound < 0 {
		return fmt.Errorf(
			"%w: task_run.review.request_round must be zero or positive: %d",
			ErrValidation,
			lineage.RequestRound,
		)
	}
	if lineage.ReviewRound < 0 {
		return fmt.Errorf(
			"%w: task_run.review.review_round must be zero or positive: %d",
			ErrValidation,
			lineage.ReviewRound,
		)
	}
	if lineage.PolicySnapshot.Normalize() != "" {
		if err := lineage.PolicySnapshot.Validate("task_run.review.policy_snapshot"); err != nil {
			return err
		}
	}
	if strings.TrimSpace(lineage.ReviewID) != "" {
		if strings.TrimSpace(lineage.ParentRunID) == "" {
			return fmt.Errorf("%w: task_run.review.parent_run_id is required when review_id is set", ErrValidation)
		}
		if lineage.ReviewRound <= 0 {
			return fmt.Errorf("%w: task_run.review.review_round must be positive when review_id is set", ErrValidation)
		}
	}
	if err := validateBoundedReviewText(
		lineage.ContinuationReason,
		maxRunReviewReasonBytes,
		"task_run.review.continuation_reason",
	); err != nil {
		return err
	}
	if err := validateRunReviewMissingWork(normalizeReviewMissingWork(lineage.MissingWork)); err != nil {
		return err
	}
	return validateBoundedReviewText(
		lineage.NextRoundGuidance,
		maxRunReviewGuidanceBytes,
		"task_run.review.next_round_guidance",
	)
}

func validateRunLeaseMetadata(r Run) error {
	claimToken := strings.TrimSpace(r.ClaimToken)