Commit 88876295 authored by nanahira's avatar nanahira

fix

parent 3ea6e32c
......@@ -240,6 +240,7 @@ export class RedisDriver extends BaseDriver {
async queueClear(key: string): Promise<void> {
const _key = this.getQueueKey(key);
await this.pool.use((r) => r.redis.del(_key));
const backupKey = this.getQueueBackupKey(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