enable delete in bulk

kube-HPC · Jan 6, 2019 · a75f8d6 · a75f8d6
1 parent 3142fd1
commit a75f8d6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/adapter.js b/lib/adapter.js
@@ -41,7 +41,11 @@ class RedisAdapter {
         if (!path.startsWith('/')) {
             path = pathLib.join('/', path);
         }
-        return client.del(path);
+        const jobIds = await this.list(options);
+        const keysToDelete = jobIds.map(x => ['del', x.path]);
+        return new Promise((resolve, reject) => {
+            client.multi(keysToDelete).exec().then(data => resolve(data), error => reject(error));
+        });
     }
 
     _set(options) {