Используя цветок, я могу отменить или добавить потребителя для конкретного работника на конкретном узле.
Однако, используя CLI, у меня происходит сбой, и я получаю эту ошибку:
Ошибка: ни один узел не ответил в пределах ограничение по времени.
Это команда :
$ celery control -d worker1@my_node -b redis://remote_broker:6379 cancel_consumer queue_name
дает мне по истечении 1-2 с тайм-аута
>> Error: No nodes replied within time constraint.
Глядя на статус, который я могу ясно видеть, что я могу достичь своего работника / узла
$ celery status -b redis://remote_broker:6379
worker1@my_node: OK
worker2@my_node: OK
worker3@my_node: OK
worker4@my_node: OK
4 nodes online. (Not realy sure why celery says 4 nodes, when there is one node and 4 workers [at least in documentation right side is called node])
Есть идеи, почему я не могу удаленно отменять / добавлять потребителей к отдельным работникам с помощью CLI?