Method loadJobsFromDB

server/modules/jobModule.js:326–353

()

  }

  async loadJobsFromDB() {
    try {
      const jobs = await Job.findAll();
      const jobVideos = await JobVideo.findAll();

      this.jobs = {};

      for (let job of jobs) {
        this.jobs[job.id] = {
          ...job.dataValues,
          data: {
            videos: [],
          },
          // Don't restore action functions - pending jobs will be terminated on startup
          // since they can't be safely resumed (missing urls, etc.)
        };
      }

      for (let jobVideo of jobVideos) {
        const video = await Video.findOne({ where: { id: jobVideo.video_id } });
        if (video && this.jobs[jobVideo.job_id]) {
          this.jobs[jobVideo.job_id].data.videos.push(video.dataValues);
        }
      }
    } catch (error) {
      logger.error({ err: error }, 'Error loading jobs from DB');
    }
  }

  async migrateJobsFromFile() {
    for (let jobId in this.jobs) {