My celery workflow:
group1 = (task1, task2) chain2 = (task3, group1) group3 = (task4, task5, chain2)
When I start group3 , everything goes well: the whole task is done with the “dependency” that I need. Tasks perform some operation and then return a boolean value. I would like to check the result of each task. Unfortunately, I cannot get all the results:
group3.results
returns:
True, True, tuple
The tuple looks something like this:
('8a8b7c2c-db44-4096-ba29-93ad2cd63409', [('576966ec-0ce5-4d82-9ab5-a23da805299b', None), ('777c77a3-34d6-4021-943f-8c39e7e87311', None)])
And I can't handle it as a result of the chain. If I create asyncresult with id 8a8b7c2c-db44-4096-ba29-93ad2cd63409 , I can only access the results of the subtask in the group (i.e. Get the results of task1 and task2 , but not get the result of task3 ).
This method is extremely complicated, but I can not find something specific in the celery documentation, where I found the whole method for obtaining simple group / chain results.
Given the fact that I really know the workflow, what is the best way to access all the results?
source share