fix: handle an error of timer.Wait

aquaproj · Jan 11, 2025 · a66f099 · a66f099
1 parent fa79338
commit a66f099
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/controller/vacuum/controller.go b/pkg/controller/vacuum/controller.go
@@ -90,7 +90,9 @@ func (vc *Controller) withDBRetry(ctx context.Context, logE *logrus.Entry, fn fu
 
 		logerr.WithError(logE, err).WithField("attempt", i+1).Warn("retrying database operation")
 
-		timer.Wait(ctx, backoff)
+		if err := timer.Wait(ctx, backoff); err != nil {
+			return fmt.Errorf("wait for retrying database operation: %w", err)
+		}
 		backoff *= exponentialBackoff
 	}