X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Futils.ts;h=619e2061f382cd82e8b30666149fd4ef11578045;hb=3c9123c7bc41a8815d7371d591ae88e38637bc42;hp=a6a52f0c663d246fcd4d2d5a1b560801eaa00921;hpb=32b141fddfba99a275b6e18b5abd97c7a66513be;p=poolifier.git diff --git a/src/pools/utils.ts b/src/pools/utils.ts index a6a52f0c..619e2061 100644 --- a/src/pools/utils.ts +++ b/src/pools/utils.ts @@ -29,7 +29,7 @@ export const getDefaultTasksQueueOptions = ( concurrency: 1, taskStealing: true, tasksStealingOnBackPressure: true, - tasksFinishedTimeout: 1000 + tasksFinishedTimeout: 2000 } } @@ -164,7 +164,6 @@ export const checkWorkerNodeArguments = ( * @param measurementStatistics - The measurement statistics to update. * @param measurementRequirements - The measurement statistics requirements. * @param measurementValue - The measurement value. - * @param numberOfMeasurements - The number of measurements. * @internal */ const updateMeasurementStatistics = ( @@ -351,7 +350,7 @@ export const waitWorkerNodeEvents = async < resolve(events) } }) - if (timeout > 0) { + if (timeout >= 0) { setTimeout(() => { resolve(events) }, timeout)