Method runSaveRetry

server/modules/jobModule.js:1072–1111

(jobId, attempt)

  }

  async runSaveRetry(jobId, attempt) {
    const jobBeforeRetry = this.jobs[jobId];
    if (!jobBeforeRetry) {
      logger.warn({ jobId, attempt }, 'Retry attempt skipped - job no longer exists in memory');
      return;
    }

    try {
      await this.saveJobs();
    } catch (err) {
      logger.error({ err, jobId, attempt }, 'Retry attempt for job failed while saving jobs');
    }

    const jobAfterRetry = this.jobs[jobId];
    if (!jobAfterRetry) {
      logger.warn({ jobId, attempt }, 'Retry attempt completed but job is no longer tracked');
      return;
    }

    if (!jobAfterRetry._needsSave) {
      // Retry succeeded - clear counters if present
      if (jobAfterRetry._saveRetries) {
        logger.debug({ jobId, attempt }, 'Successfully saved job after retry attempt, clearing retry flags');
        delete jobAfterRetry._saveRetries;
      }
      return;
    }

    if (attempt >= MAX_SAVE_RETRIES) {
      logger.error({ jobId, maxRetries: MAX_SAVE_RETRIES }, 'Max retries exhausted for job. Video data may be lost. Giving up.');
      delete jobAfterRetry._needsSave;
      delete jobAfterRetry._saveRetries;
      return;
    }

    const nextAttempt = attempt + 1;
    jobAfterRetry._saveRetries = nextAttempt;
    logger.error({ jobId, attempt, nextAttempt, maxRetries: MAX_SAVE_RETRIES }, 'Retry attempt did not clear the pending save. Scheduling next attempt');
    this.scheduleSaveRetry(jobId, nextAttempt);
  }
}

module.exports = new JobModule();