checkFilePath,
checkValidTasksQueueOptions,
checkValidWorkerChoiceStrategy,
checkFilePath,
checkValidTasksQueueOptions,
checkValidWorkerChoiceStrategy,
*/
protected async destroyWorkerNode (workerNodeKey: number): Promise<void> {
this.flagWorkerNodeAsNotReady(workerNodeKey)
*/
protected async destroyWorkerNode (workerNodeKey: number): Promise<void> {
this.flagWorkerNodeAsNotReady(workerNodeKey)
- // FIXME: wait for tasks to be finished
- // await waitWorkerNodeEvents(
- // workerNode,
- // 'taskFinished',
- // workerNode.usage.tasks.executing
- // )
+ await waitWorkerNodeEvents(workerNode, 'taskFinished', flushedTasks)
const promiseResponse = this.promiseResponseMap.get(taskId as string)
if (promiseResponse != null) {
const { resolve, reject, workerNodeKey, asyncResource } = promiseResponse
const promiseResponse = this.promiseResponseMap.get(taskId as string)
if (promiseResponse != null) {
const { resolve, reject, workerNodeKey, asyncResource } = promiseResponse
if (workerError != null) {
this.emitter?.emit(PoolEvents.taskError, workerError)
asyncResource != null
if (workerError != null) {
this.emitter?.emit(PoolEvents.taskError, workerError)
asyncResource != null
this.afterTaskExecutionHook(workerNodeKey, message)
this.workerChoiceStrategyContext.update(workerNodeKey)
this.promiseResponseMap.delete(taskId as string)
this.afterTaskExecutionHook(workerNodeKey, message)
this.workerChoiceStrategyContext.update(workerNodeKey)
this.promiseResponseMap.delete(taskId as string)