0

有人知道为什么我会出现这个问题以及如何解决它吗？我不手动删除任何作业，仅使用我为具有不同参数.removeOnComplete(true)的同一作业使用一些不同的作业处理器。task可能会导致问题吗？这种情况下该怎么办？

queue.create('task', jobData)
    .removeOnComplete(true)
    .priority('normal')
    .attempts(3)
    .save()

queue.process('task', 5, function (job, ctx, done) {
    // First task prcessor
});

queue.process('task', 5, function (job, ctx, done) {
    // Second task prcessor
});

错误：

Error: job "425596" doesnt exist
     at Command.callback (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/kue/lib/queue/job.js:178:17)
     at normal_reply (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/redis/index.js:714:21)
     at RedisClient.return_reply (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/redis/index.js:816:9)
     at JavascriptRedisParser.Parser.returnReply (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/redis/index.js:188:18)
     at JavascriptRedisParser.execute (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/redis-parser/lib/parser.js:415:12)
     at Socket.<anonymous> (/home/carmod/www/avitoparser/bundle/programs/server/npm/node_modules/redis/index.js:267:27)
     at emitOne (events.js:77:13)
     at Socket.emit (events.js:169:7)
     at readableAddChunk (_stream_readable.js:153:18)
     at Socket.Readable.push (_stream_readable.js:111:10)
4

0 回答 0