add missing error handling

pepov · pepov · commit 5ffa49f4d050 · 2024-02-09T09:44:53.000+01:00
Signed-off-by: Peter Wilcsinszky &lt;peter.wilcsinszky@axoflow.com&gt;
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 {

Original file line number	Diff line number	Diff line change
`@@ -101,9 +101,10 @@ func (r *Reconciler) configureOutputsForTenants(ctx context.Context, tenants []v`
`101`	`101`	`return errors.WrapIf(err, "getting logging resource")`
`102`	`102`	`}`
`103`	`103`
`104`		`- loggingResources, errs := r.loggingResourcesRepo.LoggingResourcesFor(ctx, *logging)`
`105`		`- if errs != nil {`
`106`		`-`
	`104`	`+ loggingResources, err := r.loggingResourcesRepo.LoggingResourcesFor(ctx, *logging)`
	`105`	`+ if err != nil {`
	`106`	`+ errs = errors.Append(errs, errors.WrapIff(err, "querying related resources for logging %s", logging.Name))`
	`107`	`+ continue`
`107`	`108`	`}`
`108`	`109`
`109`	`110`	`if loggingResources.GetFluentdSpec() != nil {`