X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=24e8a5b0c670f275a91a93dec22227fa12659d25;hb=5931725336d0de8a06146641ae6feef22bf60e6e;hp=f71bf2008c6fa955aea588e7b2c5ab905e690f47;hpb=eb7bf7441d410ca5d9ff9bb08f191ef22399371c;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index f71bf200..24e8a5b0 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -4,11 +4,12 @@ import type { MessageValue, PromiseResponseWrapper } from '../utility-types' import { DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS, EMPTY_FUNCTION, + isKillBehavior, isPlainObject, median, round } from '../utils' -import { KillBehaviors, isKillBehavior } from '../worker/worker-options' +import { KillBehaviors } from '../worker/worker-options' import { CircularArray } from '../circular-array' import { Queue } from '../queue' import { @@ -832,9 +833,7 @@ export abstract class AbstractPool< if (this.emitter != null) { this.emitter.emit(PoolEvents.taskError, message.taskError) } - promiseResponse.reject( - `${message.taskError.message} on worker '${message.taskError.workerId}'` - ) + promiseResponse.reject(message.taskError.message) } else { promiseResponse.resolve(message.data as Response) }