Method createWorkChunks

server/utils/import-queue.ts:417–470

(
    job: QueueJob,
    items: any[],
    dataType: string,
  )

  }

  private createWorkChunks(
    job: QueueJob,
    items: any[],
    dataType: string,
  ): void {
    if (!job.allocatedWorkers || !items.length) return;

    const chunkSize = Math.ceil(items.length / job.allocatedWorkers);

    const existingJob = activeJobs.get(job.id);
    if (existingJob) {
      updateJob(existingJob, {
        status: ImportStatus.ProcessingHeartbeats,
        current: 0,
        total: items.length,
      });
    }

    this.completedChunks.set(job.id, new Set());

    for (let i = 0; i < job.allocatedWorkers; i++) {
      const start = i * chunkSize;
      const end = Math.min(start + chunkSize, items.length);

      if (start < items.length) {
        const chunk: WorkChunk = {
          id: `${job.id}-chunk-${i}`,
          jobId: job.id,
          type: "date-range",
          data:
            dataType === "wakapi"
              ? {
                  dates: items.slice(start, end),
                  heartbeatsByDate: job.data.heartbeatsByDate,
                  chunkIndex: i,
                  totalChunks: job.allocatedWorkers,
                  originalJob: job,
                  processedDays: 0,
                }
              : {
                  days: items.slice(start, end),
                  chunkIndex: i,
                  totalChunks: job.allocatedWorkers,
                  originalJob: job,
                  processedDays: 0,
                },
          status: "pending",
          progress: 0,
        };

        this.workChunks.set(chunk.id, chunk);
      }
    }
  }

  private async processWorkChunk(
    chunk: WorkChunk,