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