Method startNextJob

server/modules/jobModule.js:405–429

()

  }

  async startNextJob() {
    logger.info('Looking for next job to start');
    const jobs = this.getAllJobs();
    for (let id in jobs) {
      if (jobs[id].status === 'Pending') {
        jobs[id].id = id;
        if (jobs[id].action) {
          jobs[id].action(jobs[id], true); // Invoke the function
        } else {
          // Job is missing its action function (likely loaded from DB after restart)
          logger.warn({ jobId: id, jobType: jobs[id].jobType },
            'Cannot start pending job - missing action function, marking as Terminated');

          await this.updateJob(id, {
            status: 'Terminated',
            output: 'Job could not be started after server restart',
          });

          // Try to start the next pending job
          this.startNextJob();
        }
        break;
      }
    }
  }

  async addOrUpdateJob(jobData, isNextJob = false) {
    let jobId;