schedule should also watch delayed_queue_schedule (#329)

actionhero · Mar 16, 2020 · 4608b6f · 4608b6f
1 parent b18c08b
commit 4608b6f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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