这个问题可能由于Agenda数据库中的任务被锁定而导致。为了解锁这些任务,您可以使用以下代码:
const Agenda = require('agenda'); const mongoConnectionString = 'mongodb://127.0.0.1/agenda';
const agenda = new Agenda({ db: { address: mongoConnectionString } });
agenda.on('ready', () => {
agenda._collection.update({lockedAt: {$exists: true}}, {$unset: {lockedAt: ''}}, {multi: true}, (err, numUnlocked) => {
console.log(Unlocked ${numUnlocked} jobs
);
process.exit();
})
})
运行这个脚本将会解锁Agenda数据库中的所有任务。注意,在运行这个脚本之前,你需要确保Agenda数据库已经从锁定状态中恢复过来。