diff --git a/src/core/scheduler.ts b/src/core/scheduler.ts
index f7c05c33..ddac3b10 100644
--- a/src/core/scheduler.ts
+++ b/src/core/scheduler.ts
@@ -268,6 +268,9 @@ export class Scheduler extends EventEmitter {
   private async cleanupTimestamp(timestamp: number) {
     const key = this.connection.key("delayed:" + timestamp);
     await this.connection.redis.watch(key);
+    await this.connection.redis.watch(
+      this.connection.key("delayed_queue_schedule")
+    );
     const length = await this.connection.redis.llen(key);
     if (length === 0) {
       await this.connection.redis