this.redistributeQueuedTasks(this.workerNodes.indexOf(workerNode))
}
// eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
- workerNode?.terminate().catch(error => {
+ workerNode?.terminate().catch((error: unknown) => {
this.emitter?.emit(PoolEvents.error, error)
})
})
) {
// Flag the worker node as not ready immediately
this.flagWorkerNodeAsNotReady(localWorkerNodeKey)
- this.destroyWorkerNode(localWorkerNodeKey).catch(error => {
+ this.destroyWorkerNode(localWorkerNodeKey).catch((error: unknown) => {
this.emitter?.emit(PoolEvents.error, error)
})
}
taskFunctionOperation: 'add',
taskFunctionName,
taskFunction: taskFunction.toString()
- }).catch(error => {
+ }).catch((error: unknown) => {
this.emitter?.emit(PoolEvents.error, error)
})
}
this.handleWorkerNodeIdleEvent(eventDetail, stolenTask)
return undefined
})
- .catch(error => {
+ .catch((error: unknown) => {
this.emitter?.emit(PoolEvents.error, error)
})
}