diff --git a/aleph/cache.py b/aleph/cache.py
index 25219fe78f..61d7188af2 100644
--- a/aleph/cache.py
+++ b/aleph/cache.py
@@ -70,7 +70,7 @@ def flush(self, prefix=None):
             log.info("Flush: %s", key)
             keys.append(key)
             if len(keys) > 0 and len(keys) % 1000 == 0:
-                self.kv.delete(*keys)
+                self.kv.unlink(*keys)
                 keys = []
         if len(keys) > 0:
-            self.kv.delete(*keys)
+            self.kv.unlink(*keys)