Как очистить все задачи определенной очереди с помощью сельдерея в python?

Как очистить все запланированные и запущенные задачи определенной очереди с сельдереем в python? Вопросы кажутся довольно простыми, но, чтобы добавить, я не ищу код командной строки

, у меня есть следующая строка, которая определяет очередь, и я хотел бы очистить эту очередь для управления задачами:

CELERY_ROUTES = {"socialreport.tasks.twitter_save": {"queue": "twitter_save"}}

В 1 момент времени Я хочу очистить все задачи в очереди twitter_save с помощью кода Python, возможно, с помощью функции трансляции? Мне не удалось найти документацию по этому поводу. Возможно ли это?