Требуется ли для функции отзыва дополнительные вызовы API, чтобы остановить выполнение задачи в очереди? - PullRequest
0 голосов
/ 10 сентября 2010

У меня есть рабочий с параллелизмом, установленным в 1, и задача, которая входит в бесконечный цикл [для тестирования].Я отправляю задание T1, и работник получает его и идет на работу.Я отправляю еще одно задание, оно получает его, и поскольку оно все еще занято T1, T2 переходит в очередь [rabbitMQ].

Я попытался T2.revoke () и отозвать (t2.task_id)

И проверил с инспекцией, чтобы увидеть аннулированный статус.Каждая вещь выглядит хорошо.Но когда я перезагружаю работника, он все равно выполняет T2.

Есть ли что-то, что нужно сделать, чтобы запретить выполнение T2?

1 Ответ

0 голосов
/ 06 января 2012

Возможно, вам нужно использовать постоянные аннулирования, см. здесь .

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...