How can I remove all the pending tasks in Celery and RabbitMQ?

edit

To remove all the pending tasks in Celery and RabbitMQ, you can follow these steps:

1. Stop Celery workers:

   celery multi stop <worker_name> -A <app_name>
   

2. Purge the RabbitMQ queue:

   celery -A <app_name> purge
   

   This will remove all the messages from the RabbitMQ queue.

3. Restart the Celery workers:

   celery multi start <worker_name> -A <app_name>
   

After following these steps, all the pending tasks in Celery and RabbitMQ should be removed.