X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Fdynamic.ts;h=eb93c0c8c6d5ac00908e4311f13b1b4392bc4d64;hb=e8ea58d292e381a6be7f4d0fee5d5b691adb37ac;hp=58e2b7124d749717ff90df9ad14a387f988a8c53;hpb=afd20c11f44e34385623a4b86834f69bcf660606;p=poolifier.git diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts index 58e2b712..eb93c0c8 100644 --- a/src/pools/cluster/dynamic.ts +++ b/src/pools/cluster/dynamic.ts @@ -2,7 +2,7 @@ import type { Worker } from 'cluster' import type { JSONValue } from '../../utility-types' import type { ClusterPoolOptions } from './fixed' import { FixedClusterPool } from './fixed' -import { killBehaviorEnumeration } from '../../worker/worker-options' +import { killBehaviorTypes } from '../../worker/worker-options' /** * A cluster pool with a dynamic number of workers, but a guaranteed minimum number of workers. @@ -64,7 +64,7 @@ export class DynamicClusterPool< this.registerWorkerMessageListener(worker, message => { const tasksInProgress = this.tasks.get(worker) const isKillBehaviorOptionHard = - message.kill === killBehaviorEnumeration.HARD + message.kill === killBehaviorTypes.HARD if (isKillBehaviorOptionHard || tasksInProgress === 0) { // Kill received from the worker, means that no new tasks are submitted to that worker for a while ( > maxInactiveTime) this.sendToWorker(worker, { kill: 1 })