Retrieve task result by id in Celery

by

It works using AsyncResult. (see this answer)

So first create the task:

from cel.tasks import add

res = add.delay(3,4)
print(res.status) # 'SUCCESS'
print(res.id) # '432890aa-4f02-437d-aaca-1999b70efe8d'

Then start another python shell:

from celery.result import AsyncResult
from cel.tasks import app

res = AsyncResult('432890aa-4f02-437d-aaca-1999b70efe8d',app=app)

print(res.state) # 'SUCCESS'
print(res.get()) # 7

More Related Contents:

  1. Setting Time Limit on specific task with celery
  2. Retrieve list of tasks in a queue in Celery
  3. How to dynamically add / remove periodic tasks to Celery (celerybeat)
  4. Cancel an already executing task with Celery?
  5. How do you run a worker with AWS Elastic Beanstalk?
  6. How to run celery on windows?
  7. How to check task status in Celery?
  8. Run a Scrapy spider in a Celery Task
  9. Running “unique” tasks with celery
  10. Reporting yielded results of long-running Celery task
  11. Celery Received unregistered task of type (run example)
  12. How to chain a Celery task that returns a list into a group?
  13. How can I schedule a Task to execute at a specific time using celery?
  14. Distributed task queues (Ex. Celery) vs crontab scripts
  15. How to run a celery worker with Django app scalable by AWS Elastic Beanstalk?
  16. Understanding celery task prefetching
  17. Running Scrapy spiders in a Celery task
  18. Celery with Amazon SQS
  19. Celery: is there a way to write custom JSON Encoder/Decoder?
  20. Django Celery Logging Best Practice
  21. Detect whether Celery is Available/Running
  22. Multiple Docker containers and Celery
  23. How to combine Celery with asyncio?

Leave a Comment