better multi-master maintenance queue mgmt

timgit · Mar 28, 2020 · efee899 · efee899
1 parent 11dffb8
commit efee899
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/boss.js b/src/boss.js
@@ -48,15 +48,13 @@ class Boss extends EventEmitter {
 
   async supervise () {
     await this.config.manager.deleteQueue(plans.completedJobPrefix + queues.MAINTENANCE)
-    await this.config.manager.deleteQueue(queues.MAINTENANCE)
 
     await this.maintenanceAsync()
 
     await this.config.manager.subscribe(queues.MAINTENANCE, { batchSize: 10 }, (jobs) => this.onMaintenance(jobs))
 
     if (this.monitorStates) {
       await this.config.manager.deleteQueue(plans.completedJobPrefix + queues.MONITOR_STATES)
-      await this.config.manager.deleteQueue(queues.MONITOR_STATES)
 
       await this.monitorStatesAsync()
 
@@ -70,6 +68,7 @@ class Boss extends EventEmitter {
       keepUntilSeconds: this.maintenanceIntervalSeconds * 2
     }
 
+    await this.config.manager.deleteQueue(queues.MAINTENANCE)
     await this.config.manager.publish(queues.MAINTENANCE, null, options)
   }
 
@@ -79,6 +78,7 @@ class Boss extends EventEmitter {
       keepUntilSeconds: this.monitorIntervalSeconds * 2
     }
 
+    await this.config.manager.deleteQueue(queues.MONITOR_STATES)
     await this.config.manager.publish(queues.MONITOR_STATES, null, options)
   }