/** @inheritDoc */
protected async destroyWorkerNode (workerNodeKey: number): Promise<void> {
+ this.flagWorkerNodeAsNotReady(workerNodeKey)
this.flushTasksQueue(workerNodeKey)
// FIXME: wait for tasks to be finished
const workerNode = this.workerNodes[workerNodeKey]
worker.kill()
})
await this.sendKillMessageToWorker(workerNodeKey)
+ workerNode.removeAllListeners()
worker.disconnect()
await waitWorkerExit
}