Method processWorkChunk

server/utils/import-queue.ts:472–503

(
    chunk: WorkChunk,
    workerId: number,
  )

  }

  private async processWorkChunk(
    chunk: WorkChunk,
    workerId: number,
  ): Promise<void> {
    try {
      const jobId = chunk.jobId;
      const job = activeJobs.get(jobId);
      if (!job) {
        handleLog(`Job ${jobId} not found for chunk ${chunk.id}`);
        return;
      }
      if (chunk.type === "date-range" && chunk.data.days) {
        await this.processDateRangeChunk(chunk, job, workerId);
      }

      chunk.status = "completed";
      chunk.progress = 100;

      const completedSet = this.completedChunks.get(chunk.jobId);
      if (completedSet) {
        completedSet.add(chunk.id);
      }

      this.updateJobProgress(chunk.jobId);
      await this.checkJobCompletion(chunk.jobId);
    } catch (error) {
      chunk.status = "failed";
      handleLog(`Worker ${workerId} failed chunk ${chunk.id}: ${error}`);
    } finally {
      this.cleanupWorkerAssignment(workerId);
    }
  }

  private async processDateRangeChunk(
    chunk: WorkChunk,