From 3a20ee0d46e05d4ba5a672b9de52ce9a30223b3a Mon Sep 17 00:00:00 2001 From: "eng.mohwahab@gmail.com" Date: Thu, 19 Sep 2024 21:43:30 +0300 Subject: [PATCH] fix: only dequeue if status is stopped --- libs/eventually/src/utils/scheduler.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libs/eventually/src/utils/scheduler.ts b/libs/eventually/src/utils/scheduler.ts index 67d6e54a..2478a1a3 100644 --- a/libs/eventually/src/utils/scheduler.ts +++ b/libs/eventually/src/utils/scheduler.ts @@ -63,7 +63,7 @@ export const scheduler = (name: string): Schedule => { const enqueue = (action: Action): void => { if (_status === "stopping" || _status === "paused") return; queue.push(action); - setImmediate(dequeue); + _status === "stopped" && setImmediate(dequeue); }; const dequeue = async (): Promise => {