В моем sharedtask я звоню несколько subtasks(...).apply_async(). Таким образом, и родительская задача, и подзадачи имеют свои собственные task_id.
Когда я отменяю всю операцию, я вызываю отзыв всех активных задач, и она работает правильно. Но как только ядра освобождаются, очередь продолжается, выполняя следующие подзадачи.
Как программно очистить очередь, тем самым предотвращая выполнение следующих подзадач?