Celery - как остановить выполнение задачи при использовании распределенного бэкэнда RabbitMQ?

Question

Если я запускаю Celery на (скажем) банке из 50 машин, все из которых используют распределенный кластер RabbitMQ.

Если у меня есть задача, которая выполняется, и я знаю идентификатор задачи, то как в мире можноСельдерей выяснить, на какой машине он работает, чтобы прекратить его?

Спасибо.

Answer 1

Я не уверен, что вы действительно сможете это сделать, когда вы создадите задачу, у вас будет рабочий, где-то в 50 ящиках, который его выполняет, и вы технически не имеете над ним контроля, поскольку это отдельный процесс и единственныйто, что вы можете контролировать, это либо asyncResult, либо сообщение amqp в очереди.