Function gracefulShutdown

lib/schedule.js:76–105

()

}

function gracefulShutdown() {
  const jobs = Object.keys(scheduledJobs).map(key => scheduledJobs[key]);
  jobs.forEach(function (job) {
    job.cancel();
  });

  let running = false;
  for (let i = 0; i < jobs.length; i++) {
    if (jobs[i].running > 0) {
      running = true;
      break;
    }
  }

  return new Promise(function (resolve) {
    if (running) {
      setInterval(function () {
        for (let i = 0; i < jobs.length; i++) {
          if (jobs[i].running > 0) {
            return;
          }
        }

        resolve();
      }, 500);
    } else {
      resolve();
    }
  });
}

/* Public API */
module.exports = {