Как я могу проверить, была ли добавлена ​​​​задача в очередь RabbitMQ с помощью приложения Celery в Flask? ⇐ Python

[Anonymous]

Я работаю над приложением Flask, используя Celery и RabbitMQ в качестве брокера сообщений.
Я хочу проверить, была ли задача успешно добавлена ​​в очередь RabbitMQ, прежде чем она начнет обрабатываться.
В настоящее время я использую AsyncResult(task_id) для проверки статуса задачи. Но он отвечает «Ожидает», когда я проверяю идентификатор задачи, которая никогда не была создана.
Есть ли способ проверить, была ли задача добавлена ​​в очередь в RabbitMQ, используя Celery в Flask ?
Кто-нибудь сталкивался с этой проблемой, и если да, то как лучше всего ее решить?
Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/792 ... y-in-flask