@@ -93,19 +93,19 @@ func (s *csvSource) Snapshot(ctx context.Context) (*cache.Snapshot, error) {
93
93
continue
94
94
}
95
95
96
- if cachedSubscription , ok := csvSubscriptions [csv ]; ! ok || cachedSubscription == nil {
97
- // we might be in an incoherent state, so let's check with live clients to make sure
98
- realSubscriptions , err := s .listSubscriptions (ctx )
99
- if err != nil {
100
- return nil , fmt .Errorf ("failed to list subscriptions: %w" , err )
101
- }
102
- for _ , realSubscription := range realSubscriptions .Items {
103
- if realSubscription .Status .InstalledCSV == csv .Name {
104
- // oops, live cluster state is coherent
105
- return nil , fmt .Errorf ("lister caches incoherent for CSV %s/%s - found owning Subscription %s/%s" , csv .Namespace , csv .Name , realSubscription .Namespace , realSubscription .Name )
106
- }
107
- }
108
- }
96
+ // if cachedSubscription, ok := csvSubscriptions[csv]; !ok || cachedSubscription == nil {
97
+ // // we might be in an incoherent state, so let's check with live clients to make sure
98
+ // realSubscriptions, err := s.listSubscriptions(ctx)
99
+ // if err != nil {
100
+ // return nil, fmt.Errorf("failed to list subscriptions: %w", err)
101
+ // }
102
+ // for _, realSubscription := range realSubscriptions.Items {
103
+ // if realSubscription.Status.InstalledCSV == csv.Name {
104
+ // // oops, live cluster state is coherent
105
+ // return nil, fmt.Errorf("lister caches incoherent for CSV %s/%s - found owning Subscription %s/%s", csv.Namespace, csv.Name, realSubscription.Namespace, realSubscription.Name)
106
+ // }
107
+ // }
108
+ // }
109
109
110
110
if failForwardEnabled {
111
111
replacementChainEndsInFailure , err := isReplacementChainThatEndsInFailure (csv , ReplacementMapping (csvs ))
0 commit comments