Retrieve list of tasks in a queue in Celery

by

EDIT: See other answers for getting a list of tasks in the queue.

You should look here:
Celery Guide – Inspecting Workers

Basically this:

my_app = Celery(...)

# Inspect all nodes.
i = my_app.control.inspect()

# Show the items that have an ETA or are scheduled for later processing
i.scheduled()

# Show tasks that are currently active.
i.active()

# Show tasks that have been claimed by workers
i.reserved()

Depending on what you want

More Related Contents:

  1. How to dynamically add / remove periodic tasks to Celery (celerybeat)
  2. Cancel an already executing task with Celery?
  3. How to run celery on windows?
  4. How to check task status in Celery?
  5. Running “unique” tasks with celery
  6. Reporting yielded results of long-running Celery task
  7. Celery Received unregistered task of type (run example)
  8. How to chain a Celery task that returns a list into a group?
  9. How can I schedule a Task to execute at a specific time using celery?
  10. Distributed task queues (Ex. Celery) vs crontab scripts
  11. Understanding celery task prefetching
  12. Running Scrapy spiders in a Celery task
  13. Celery: is there a way to write custom JSON Encoder/Decoder?
  14. Django Celery Logging Best Practice
  15. Detect whether Celery is Available/Running
  16. How to combine Celery with asyncio?
  17. value error in python script
  18. Remove multiples of numbers out of a list – Python
  19. How to properly ignore exceptions
  20. In Python, how do I convert all of the items in a list to floats?
  21. Non blocking subprocess.call
  22. Why is my NLTK function slow when processing the DataFrame?
  23. python selenium, find out when a download has completed?
  24. efficiently checking that string consists of one character in Python
  25. How to know which Python is running in Jupyter notebook?
  26. How to make a sunburst plot in R or Python?
  27. Import Python Script Into Another?
  28. How do I connect microbit with BLE and listen for button press events?
  29. How to decompile an exe file compiled by py2exe?
  30. Django filter JSONField list of dicts

Leave a Comment