Method updateJobProgress

server/utils/import-queue.ts:555–615

(jobId: string)

  }

  private updateJobProgress(jobId: string): void {
    const job = activeJobs.get(jobId);
    if (!job) {
      handleLog(`[queue] Job ${jobId} not found for progress update`);
      return;
    }

    const jobChunks = Array.from(this.workChunks.values()).filter(
      (c) => c.jobId === jobId,
    );

    if (jobChunks.length === 0) {
      handleLog(`[${getLogPrefix(job.type)}] No chunks found for job ${jobId}`);
      return;
    }

    const totalProcessedDays = jobChunks.reduce(
      (sum, chunk) => sum + (chunk.data.processedDays || 0),
      0,
    );

    const oldProgress = job.progress;
    const oldProcessedCount = job.processedCount || 0;

    job.processedCount = totalProcessedDays;
    job.progress = job.totalToProcess
      ? Math.min(
          99,
          Math.round((totalProcessedDays / job.totalToProcess) * 100),
        )
      : Math.min(
          99,
          Math.round(
            jobChunks.reduce((sum, chunk) => sum + chunk.progress, 0) /
              jobChunks.length,
          ),
        );

    job.status = ImportStatus.ProcessingHeartbeats;
    job.message = formatStatus(
      ImportStatus.ProcessingHeartbeats,
      job.type,
      job.processedCount,
      job.totalToProcess,
      job.progress,
      undefined,
      job.importedCount,
      job.error,
    );

    activeJobs.set(jobId, job);

    if (
      oldProgress !== job.progress ||
      oldProcessedCount !== job.processedCount
    ) {
      handleLog(
        `[${getLogPrefix(job.type)}] Job ${jobId} progress: ${job.processedCount}/${job.totalToProcess} days (${job.progress}%)`,