fix: ensure worker choice strategies internals are updated after tasks
authorJérôme Benoit <jerome.benoit@sap.com>
Fri, 16 Jun 2023 19:56:18 +0000 (21:56 +0200)
committerJérôme Benoit <jerome.benoit@sap.com>
Fri, 16 Jun 2023 19:56:18 +0000 (21:56 +0200)
submission

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
src/pools/abstract-pool.ts

index ac4cb31ed4576bcce9fea5dbab191e1bc11c103b..8363ecba9f8d3c98d9071023e99f4b7b47053e7a 100644 (file)
@@ -766,6 +766,7 @@ export abstract class AbstractPool<
               workerNodeKey,
               this.dequeueTask(workerNodeKey) as Task<Data>
             )
+            this.workerChoiceStrategyContext.update(workerNodeKey)
           }
         }
       }