Method requireForceRunRate

internal/task/force_ops.go:432–459

(actor ActorContext, taskID string)

}

func (m *Service) requireForceRunRate(actor ActorContext, taskID string) error {
	if actor.Actor.Kind.Normalize() != ActorKindAgentSession {
		return nil
	}
	now := m.now().UTC()
	if m.forceRateLimiter.allow(actor.Actor, taskID, now, m.forceRecovery.RateLimitPerMinute) {
		return nil
	}
	return forceRunDiagnosticError(
		diagnosticcontract.CodeForceOpRateLimited,
		"Force operation rate limit exceeded",
		fmt.Sprintf(
			"Actor %s exceeded %d force operations per minute for task %s.",
			actor.Actor.Ref,
			m.forceRecovery.RateLimitPerMinute,
			taskID,
		),
		diagnosticcontract.SeverityWarn,
		"agh task inspect "+taskID,
		map[string]any{
			"actor_kind":      string(actor.Actor.Kind.Normalize()),
			"actor_id":        actor.Actor.Ref,
			taskEvidenceIDKey: taskID,
			"limit":           m.forceRecovery.RateLimitPerMinute,
		},
		ErrForceOpRateLimited,
	)
}

func (m *Service) invalidateForceRunInputs(ctx context.Context, previous Run) (int64, int, error) {
	sessionID := strings.TrimSpace(previous.SessionID)