Когда я использую CloudAMQP, он не отменяет задачи, когда я запускаю следующий код в моем Django приложении:
task_id = campaign.celery_task_id
app.control.revoke(task_id)
Вместо этого приложение просто зависает. Однако я могу создавать задачи сельдерея из моего приложения Django при использовании CloudAMQP, просто не могу их отменить. Также для приведенного выше кода, отменяющего задачу, он работал с Redis в качестве URL-адреса брокера. Я также попытался изменить его на app.control.revoke(task_id, terminate=True), но все еще глохнет. Я пытаюсь отозвать задачи, которые были установлены на запланированное время в будущем, используя следующий код email_campaign.apply_async((audience_id, campaign_id), eta=scheduled_time_utc)