fix: regression in queue init (chrisleekr#581)

Ailein · Jan 12, 2023 · 4be42b9 · 4be42b9
1 parent 98b756e
commit 4be42b9
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/app/cronjob/trailingTradeHelper/queue.js b/app/cronjob/trailingTradeHelper/queue.js
@@ -1,8 +1,8 @@
 const _ = require('lodash');
 const { executeTrailingTrade } = require('../index');
 
-let startedJobs = {};
-let finishedJobs = {};
+const startedJobs = {};
+const finishedJobs = {};
 
 /**
  * Initialize queue counters for symbols
@@ -13,13 +13,12 @@ let finishedJobs = {};
 const init = async (funcLogger, symbols) => {
   const logger = funcLogger.child({ helper: 'queue' });
 
-  startedJobs = {};
-  finishedJobs = {};
-
   await Promise.all(
     _.map(symbols, async symbol => {
-      startedJobs[symbol] = 0;
-      finishedJobs[symbol] = 0;
+      if (startedJobs[symbol] === undefined) {
+        startedJobs[symbol] = 0;
+        finishedJobs[symbol] = 0;
+      }
     })
   );