Method terminateInProgressJobs

server/modules/jobModule.js:211–319

()

  }

  async terminateInProgressJobs() {
    // Change the status of "In Progress" jobs to "Terminated" and recover/cleanup videos
    for (let jobId in this.jobs) {
      if (this.jobs[jobId].status === 'In Progress') {
        logger.info({ jobId }, 'Recovering job after server restart');

        let recoveredCount = 0;
        let outputMessage = 'Job terminated due to server restart';

        try {
          // Step 1: Recover completed videos from JobVideoDownload table
          recoveredCount = await this.recoverCompletedVideos(jobId);

          // Step 2: Clean up in-progress videos from disk
          try {
            await downloadCleanup.cleanupInProgressVideos(jobId);
          } catch (cleanupErr) {
            logger.error({ err: cleanupErr, jobId }, 'Error cleaning up in-progress videos for job');
          }

          // Step 3: Set appropriate output message
          if (recoveredCount > 0) {
            outputMessage = `${recoveredCount} video${recoveredCount === 1 ? '' : 's'} completed (recovered after server restart)`;
          }

          // Step 4: Clean up all JobVideoDownload entries for this job
          try {
            const deletedCount = await JobVideoDownload.destroy({
              where: { job_id: jobId }
            });
            if (deletedCount > 0) {
              logger.info({ jobId, deletedCount }, 'Cleaned up JobVideoDownload tracking entries for job');
            }
          } catch (deleteErr) {
            logger.error({ err: deleteErr, jobId }, 'Error deleting JobVideoDownload entries for job');
          }
        } catch (err) {
          logger.error({ err, jobId }, 'Error during recovery for job');
          outputMessage = `Job terminated with errors: ${err.message}`;
        }

        // Step 5: Reload job videos from database into in-memory structure
        // This ensures Download History shows the correct count
        try {
          const jobVideos = await JobVideo.findAll({
            where: { job_id: jobId }
          });

          const videos = [];
          for (const jobVideo of jobVideos) {
            const video = await Video.findOne({ where: { id: jobVideo.video_id } });
            if (video) {
              videos.push(video.dataValues);
            }
          }

          if (!this.jobs[jobId].data) {
            this.jobs[jobId].data = {};