diff --git a/server/pkg/controller/data_cleanup/controller.go b/server/pkg/controller/data_cleanup/controller.go index 05727ff0c..8b4727585 100644 --- a/server/pkg/controller/data_cleanup/controller.go +++ b/server/pkg/controller/data_cleanup/controller.go @@ -190,8 +190,15 @@ func (c *DeleteUserCleanupController) storageCheck(ctx context.Context, item *en } func (c *DeleteUserCleanupController) isDeleted(item *entity.DataCleanup) error { - _, err := c.UserRepo.Get(item.UserID) + u, err := c.UserRepo.Get(item.UserID) if err == nil { + // user is not deleted, double check by verifying email is not empty + if u.Email != "" { + remErr := c.Repo.RemoveScheduledDelete(context.Background(), item.UserID) + if remErr != nil { + return stacktrace.Propagate(remErr, "failed to remove scheduled delete entry") + } + } return stacktrace.Propagate(ente.NewBadRequestWithMessage("User ID is linked to undeleted account"), "") } if !errors.Is(err, ente.ErrUserDeleted) {