fix(runWebScraper): don't move to completed
This commit is contained in:
@@ -131,7 +131,7 @@ const saveJob = async (job: Job, result: any) => {
|
|||||||
|
|
||||||
if (error) throw new Error(error.message);
|
if (error) throw new Error(error.message);
|
||||||
try {
|
try {
|
||||||
await job.moveToCompleted(null, false, false);
|
// await job.moveToCompleted(null, false, false);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
// I think the job won't exist here anymore
|
// I think the job won't exist here anymore
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -68,7 +68,7 @@ async function processJob(job: Job, done) {
|
|||||||
});
|
});
|
||||||
Logger.info(`🐂 Job done ${job.id}`);
|
Logger.info(`🐂 Job done ${job.id}`);
|
||||||
clearInterval(lockInterval);
|
clearInterval(lockInterval);
|
||||||
done(null, data);
|
done(null, null);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
Logger.error(`🐂 Job errored ${job.id} - ${error}`);
|
Logger.error(`🐂 Job errored ${job.id} - ${error}`);
|
||||||
if (await getWebScraperQueue().isPaused(false)) {
|
if (await getWebScraperQueue().isPaused(false)) {
|
||||||
|
|||||||
Reference in New Issue
Block a user