Method createAsyncWorker

server/utils/import-queue.ts:329–349

(workerId: number)

  }

  private async createAsyncWorker(workerId: number): Promise<void> {
    while (true) {
      try {
        const workItem = await this.getNextWorkItem(workerId);

        if (workItem.job) {
          await this.processJob(workItem.job, workerId);
        } else if (workItem.chunk) {
          await this.processWorkChunk(workItem.chunk, workerId);
        } else {
          await new Promise((resolve) => setTimeout(resolve, 1000));
        }
      } catch (error) {
        handleLog(
          `[worker] Worker ${workerId} error: ${error instanceof Error ? error.message : String(error)}`,
        );
        this.cleanupWorkerAssignment(workerId);
        await new Promise((resolve) => setTimeout(resolve, 2000));
      }
    }
  }

  private async getNextWorkItem(
    workerId: number,