Commit f948871f authored by nanahira's avatar nanahira

Revert "fix"

This reverts commit 88876295.
parent 264372ea
...@@ -240,7 +240,6 @@ export class RedisDriver extends BaseDriver { ...@@ -240,7 +240,6 @@ export class RedisDriver extends BaseDriver {
async queueClear(key: string): Promise<void> { async queueClear(key: string): Promise<void> {
const _key = this.getQueueKey(key); const _key = this.getQueueKey(key);
const backupKey = this.getQueueBackupKey(key); await this.pool.use((r) => r.redis.del(_key));
await this.pool.use((r) => r.redis.multi().del(_key).del(backupKey).exec());
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment