X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=9aeeebed772b37234c2a8f0e88c5cb45c65f0dce;hb=b0b55f57cb5e2bc363bc75d84b483c9c29a5d22f;hp=33585218249e599cd1998fdc19158e7ab4b22168;hpb=adee605399485348ae224e7e4c022f024373b0ef;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 33585218..9aeeebed 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -782,9 +782,11 @@ export abstract class AbstractPool< ) { reject( new Error( - `Task function operation ${ + `Task function operation '${ message.taskFunctionOperation as string - } failed on worker ${message.workerId}` + }' failed on worker ${message.workerId} with error: '${ + message.workerError?.message as string + }'` ) ) } @@ -815,11 +817,18 @@ export abstract class AbstractPool< message => message.taskFunctionOperationStatus === false ) ) { + const errorResponse = responsesReceived.find( + response => response.taskFunctionOperationStatus === false + ) reject( new Error( - `Task function operation ${ + `Task function operation '${ message.taskFunctionOperation as string - } failed on worker ${message.workerId as number}` + }' failed on worker ${ + errorResponse?.workerId as number + } with error: '${ + errorResponse?.workerError?.message as string + }'` ) ) }