Невозможно удалить повторяющееся задание из узла Bull Queue Js - PullRequest
0 голосов
/ 07 марта 2019

Когда я пытался использовать этот метод - removeRepeatableByKey Я получаю removeRepeatableByKey не является ошибкой функции. queue_1.taskQueue.removeRepeatableByKey не является функцией

Я не могу удалить повторяющуюся работу с помощью taskQueue.removeRepeatable('task', { cron: '0 47 6 * * 4' }); это тоже

let jobOptions = {
        priority: queue_options.priority,
        repeat: { cron: '0 47 6 * * 4'},
        attempts: 3,
        removeOnComplete: true,
        jobId: queue_options.job_id,
        backoff: 3,
        timeout: 60000,
      };
      taskQueue.add('task', queue_options.data, jobOptions);

JSON из JOB:

{ id: "repeat:09854c8042eced1337a7d8eec9357528:1552526220000", name: "task", data: { eventName: "test", parameters: [ { my_JSON }, { my_JSON } ] }, opts: { repeat: { count: 1, cron: "0 47 6 * * 4", jobId: "myJobId" }, jobId: "repeat:09854c8042eced1337a7d8eec9357528:1552526220000", delay: 603096068, timestamp: 1551923123932, prevMillis: 1552526220000, priority: 1, attempts: 3, removeOnComplete: true, backoff: { type: "fixed", delay: 3 }, timeout: 60000 }, progress: 0, delay: 603096068, timestamp: 1551923123932, attemptsMade: 0, stacktrace: [ ], returnvalue: null, finishedOn: null, processedOn: null }

1 Ответ

0 голосов
/ 11 марта 2019

Теперь я могу удалить повторяемую работу. Проблема была в том, что я добавляю задание в очередь с помощью:

let jobOptions = {
        priority: queue_options.priority,
        repeat: { cron: '0 47 6 * * 4' },
        attempts: 3,
        removeOnComplete: true,
        jobId: queue_options.job_id,
        backoff: 3,
        timeout: 60000,
      };
      taskQueue.add('task', queue_options.data, jobOptions);

И пытается удалить работу, как:

let job = await taskQueue.removeRepeatable('task', {cron : '0 47 6 * * 4'});

Я исправил это, передав jobOptions и смог успешно удалить задание из очереди.

let job = await taskQueue.removeRepeatable('task' jobOptions);
...