distributed system

How to solve celery task has no attribute AsyncResult

I was looking through Grinberg’s tuto on celery and flask. I saw querying tasks by task = long_task.AsyncResult(task_id) But for some reasons it was not working for me. I looked at Flower‘s get_task_by_id which led to wrapping a tornado object. It was too complicated for me to include Tornado in my project. I browsed through …

How to solve celery task has no attribute AsyncResult Read More »

How to query task by id in celery

Using celery 5.1.2 you can get the task id by the following code snippet: from celery import current_app as celery_app # in your function: celery_app.tasks[‘task_dosomething’].AsyncResult(‘task_id’) Where task_dosomething is the name of your task and task_id is the id you choose. You can learn more about setting task id here Works on windows 8