Method restartWorkerThread

server/utils/import-queue.ts:250–259

(workerId: number)

  }

  private restartWorkerThread(workerId: number): void {
    const oldWorker = this.workerThreads.get(workerId);
    if (oldWorker) {
      oldWorker.terminate();
    }
    this.workerJobAssignment.delete(workerId);
    setTimeout(() => {
      this.createWorkerThread(workerId);
    }, 2000);
  }

  private handleWorkerMessage(workerId: number, message: any): void {
    switch (message.type) {