Fix removing non-existing entries

seaweedfs · Aug 1, 2024 · 68f22a0 · 68f22a0
1 parent 9fa99d6
commit 68f22a0
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/driver/provisioner.go b/pkg/driver/provisioner.go
@@ -164,6 +164,11 @@ func (s *provisionerServer) DriverDeleteBucket(
 func (s *provisionerServer) revokeBucketAccess(ctx context.Context, userId string) error {
 	err := s.configureS3Access(ctx, userId, "", "", nil, true)
 	if err != nil {
+		// Check if the error is because the entry was not found
+		if grpc.Code(err) == codes.NotFound {
+			klog.InfoS("no entry found in filer store, treating as success", "user", userId)
+			return nil
+		}
 		return err
 	}