Method checkJobCompletion

server/utils/import-queue.ts:617–644

(jobId: string)

  }

  private async checkJobCompletion(jobId: string): Promise<void> {
    const jobChunks = Array.from(this.workChunks.values()).filter(
      (c) => c.jobId === jobId,
    );
    const completedChunks = jobChunks.filter((c) => c.status === "completed");

    if (completedChunks.length === jobChunks.length && jobChunks.length > 0) {
      const job = activeJobs.get(jobId);
      if (job) {
        const totalDaysWithData = jobChunks.reduce(
          (sum, chunk) => sum + (chunk.data.processedDays || 0),
          0,
        );

        updateJob(job, {
          status: ImportStatus.Completed,
          importedCount: totalDaysWithData,
        });
        handleLog(
          `[${getLogPrefix(job.type)}] Job ${jobId} completed - processed ${totalDaysWithData} days across ${jobChunks.length} chunks`,
        );
      }

      jobChunks.forEach((chunk) => this.workChunks.delete(chunk.id));
      this.jobWorkerCount.delete(jobId);
      this.completedChunks.delete(jobId);
    }
  }

  private async processJob(job: QueueJob, workerId: number): Promise<void> {
    try {