fix remove worker

erxes · Apr 15, 2020 · deefe38 · deefe38
1 parent 83c903a
commit deefe38
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/engages-email-sender/src/workers/utils.ts b/engages-email-sender/src/workers/utils.ts
@@ -34,6 +34,12 @@ export const createWorkers = (workerPath: string, workerData: any, results: stri
             removeWorker(worker);
           });
 
+          worker.on('message', msg => {
+            if (msg === 'Successfully finished job') {
+              removeWorker(worker);
+            }
+          });
+
           worker.on('exit', code => {
             if (code !== 0) {
               debugWorkers(`Worker stopped with exit code ${code}`);