0

我正在尝试在服务器启动时重新创建所有过期的作业。

(async function() {
  await agenda.start();
  const jobs = await agenda.jobs({nextRunAt: {$lt: new Date(Date.now())}});
  for(var job of jobs){
    var { _id, name, data, type, priority, nextRunAt, lastModifiedBy, lockedAt, lastRunAt} = job.attrs;
    var newDate = Date.now() + 30000;
    await agenda.cancel({_id:_id});
    await agenda.schedule(newDate,name,data);
  }
})();

但是,当新作业保存在数据库中时,它们不会被执行。

任何想法 ?

4

0 回答 0