我正在尝试在服务器启动时重新创建所有过期的作业。
(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);
}
})();
但是,当新作业保存在数据库中时,它们不会被执行。
任何想法 ?