/** @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
}
): void {
this.workerNodes[workerNodeKey].worker.send({
...message,
- workerId: this.workerNodes[workerNodeKey].info.id as number
+ workerId: this.getWorkerInfo(workerNodeKey).id as number
})
}