Celery + RabbitMQ: есть ли способ отключить предварительную выборку, избегая при этом запроса потерянного работника ⇐ Python

[Anonymous]

Я хочу отключить предварительную выборку для моих работников сельдерея (с использованием RabbitMQ + Redis).
Как показано здесь. Понимание предварительной выборки задачи сельдерея, чтобы отключить предварительную выборку, мне нужно установить: р>

Код: Выделить всё

worker_prefetch_multiplier = 1
acks_late = True
run the worker with -Ofair

Я сделал следующее, но поскольку я установил для acks_late значение True, если рабочий процесс потеряет соединение (например, SIGKILL), он автоматически запросит задачу, чего я не хочу.Я пытался отключить это с помощью этого параметра, но, похоже, это не повлияло на предотвращение повторной очереди.

Код: Выделить всё

reject_on_worker_lost = False

Есть ли способ отключить предварительную выборку без использования late_acks или использовать late_acks без автоматической повторной очереди?

Подробнее здесь: https://stackoverflow.com/questions/792 ... ng-requeue