Method invalidateForceRunInputs

internal/task/force_ops.go:461–484

(ctx context.Context, previous Run)

}

func (m *Service) invalidateForceRunInputs(ctx context.Context, previous Run) (int64, int, error) {
	sessionID := strings.TrimSpace(previous.SessionID)
	if sessionID == "" {
		return 0, 0, nil
	}
	queueStore, ok := m.store.(inputQueueGenerationStore)
	if !ok {
		return 0, 0, nil
	}
	now := m.now().UTC()
	generation, err := queueStore.AdvanceSessionInputGeneration(ctx, sessionID, now)
	if err != nil {
		return 0, 0, fmt.Errorf("task: advance input generation for force operation on session %q: %w", sessionID, err)
	}
	canceled, err := queueStore.CancelPendingSessionInputs(ctx, sessionID, generation, now)
	if err != nil {
		return 0, 0, fmt.Errorf(
			"task: cancel stale input generation for force operation on session %q: %w",
			sessionID,
			err,
		)
	}
	return generation, canceled, nil
}

func requireForceFailStatus(run Run) error {
	switch run.Status.Normalize() {