()
| 77 | from celery.app.control import Inspect |
| 78 | |
| 79 | def purge_celery_queue(): |
| 80 | i = Inspect(app=celery_app) |
| 81 | active_queues = i.active_queues() |
| 82 | if active_queues: |
| 83 | for queue in active_queues.keys(): |
| 84 | celery_app.control.purge() |
| 85 | |
| 86 | |
| 87 | def get_task_info(task_id: str): |