accessing celery task results in chain within a group -
my workflow celery is:
group1 = (task1, task2) chain2 = (task3, group1) group3 = (task4, task5, chain2) when start group3, goes fine: task executed "dependency" need. tasks perform operation , return boolean. check result of every task. unfortunately, not able retrieve results:
group3.results returns:
true, true, tuple the tuple like:
('8a8b7c2c-db44-4096-ba29-93ad2cd63409', [('576966ec-0ce5-4d82-9ab5-a23da805299b', none), ('777c77a3-34d6-4021-943f-8c39e7e87311', none)]) and cannot handle chain result. if create asyncresult id 8a8b7c2c-db44-4096-ba29-93ad2cd63409, can access results of subtask in group (i.e.: task1 , task2 results, no way task3 result).
this method extremely complicated, cannot find specific in celery documentation, found method retrieve simple groups/chains results.
given fact know workflow, best way access results?
Comments
Post a Comment