]> Piment Noir Git Repositories - poolifier.git/commitdiff
refactor: reorder task finished event emission
authorJérôme Benoit <jerome.benoit@piment-noir.org>
Fri, 22 Aug 2025 17:38:50 +0000 (19:38 +0200)
committerJérôme Benoit <jerome.benoit@piment-noir.org>
Fri, 22 Aug 2025 17:38:50 +0000 (19:38 +0200)
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
src/pools/abstract-pool.ts

index 10bc2ff5291b79fb46d9b952aad912e333688a45..d37d21c18d4570ed204b6580ca1d256ebbc2304a 100644 (file)
@@ -1829,11 +1829,11 @@ export abstract class AbstractPool<
       asyncResource?.emitDestroy()
       this.afterTaskExecutionHook(workerNodeKey, message)
       queueMicrotask(() => {
-        this.checkAndEmitTaskExecutionFinishedEvents()
         // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
         workerNode?.emit('taskFinished', taskId)
         // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
         this.promiseResponseMap.delete(taskId!)
+        this.checkAndEmitTaskExecutionFinishedEvents()
         if (this.opts.enableTasksQueue === true && !this.destroying) {
           if (
             !this.isWorkerNodeBusy(workerNodeKey) &&