fix: return resolve pulse.stop() case of success (#18)

* fix: return resolve pulse.stop() case of success
pulsecron · May 2, 2024 · df7e6f4 · df7e6f4
1 parent c7a3531
commit df7e6f4
Showing 1 changed file with 13 additions and 7 deletions.
diff --git a/src/pulse/stop.ts b/src/pulse/stop.ts
@@ -28,14 +28,20 @@ export const stop: StopMethod = async function (this: Pulse) {
       }
 
       debug('about to unlock jobs with ids: %O', jobIds);
-      this._collection.updateMany({ _id: { $in: jobIds } }, { $set: { lockedAt: null } }).catch((error) => {
-        if (error) {
-          reject(error);
-        }
+      this._collection
+        .updateMany({ _id: { $in: jobIds } }, { $set: { lockedAt: null } })
+        .then(() => {
+          this._lockedJobs = [];
+          return resolve();
+        })
+        .catch((error) => {
+          if (error) {
+            return reject(error);
+          }
 
-        this._lockedJobs = [];
-        resolve();
-      });
+          this._lockedJobs = [];
+          return resolve();
+        });
     });
   };