add missing error handling

Signed-off-by: Peter Wilcsinszky <peter.wilcsinszky@axoflow.com>
kube-logging · Feb 9, 2024 · 5ffa49f · 5ffa49f
1 parent e5b9ba7
commit 5ffa49f
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/pkg/resources/fluentbit/tenants.go b/pkg/resources/fluentbit/tenants.go
@@ -101,9 +101,10 @@ func (r *Reconciler) configureOutputsForTenants(ctx context.Context, tenants []v
 			return errors.WrapIf(err, "getting logging resource")
 		}
 
-		loggingResources, errs := r.loggingResourcesRepo.LoggingResourcesFor(ctx, *logging)
-		if errs != nil {
-
+		loggingResources, err := r.loggingResourcesRepo.LoggingResourcesFor(ctx, *logging)
+		if err != nil {
+			errs = errors.Append(errs, errors.WrapIff(err, "querying related resources for logging %s", logging.Name))
+			continue
 		}
 
 		if loggingResources.GetFluentdSpec() != nil {