@@ -347,20 +347,19 @@ func (r *CollectorReconciler) SetupWithManager(mgr ctrl.Manager) error {
347
347
348
348
TenantLoop:
349
349
for _ , tenant := range tenants .Items {
350
+ if tenant .Status .Collector == "" {
351
+ logger .Error (errors .WithStack (err ), fmt .Sprintf ("tenant %s is orphan, skipping it, and its subscriptions when looking for changes" , tenant .Name ))
352
+ }
350
353
subscriptionsForTenant , subscriptionsToUpdate , err := r .getSubscriptionsForTenant (ctx , & tenant )
351
354
if err != nil {
352
355
logger .Error (errors .WithStack (err ), "failed listing subscriptions for collector, notifying collector anyways" )
353
- if tenant .Status .Collector != "" {
354
- requests = addCollectorRequest (requests , tenant .Status .Collector )
355
- }
356
+ requests = addCollectorRequest (requests , tenant .Status .Collector )
356
357
continue TenantLoop
357
358
}
358
359
359
360
for _ , s := range append (subscriptionsForTenant , subscriptionsToUpdate ... ) {
360
361
if s .Name == subscription .Name {
361
- if tenant .Status .Collector != "" {
362
- requests = addCollectorRequest (requests , tenant .Status .Collector )
363
- }
362
+ requests = addCollectorRequest (requests , tenant .Status .Collector )
364
363
continue TenantLoop
365
364
}
366
365
}
@@ -369,9 +368,7 @@ func (r *CollectorReconciler) SetupWithManager(mgr ctrl.Manager) error {
369
368
370
369
for _ , s := range subscriptionsToDisown {
371
370
if s .Name == subscription .Name {
372
- if tenant .Status .Collector != "" {
373
- requests = addCollectorRequest (requests , tenant .Status .Collector )
374
- }
371
+ requests = addCollectorRequest (requests , tenant .Status .Collector )
375
372
continue TenantLoop
376
373
}
377
374
}
0 commit comments