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

Popular posts from this blog

php - Wordpress website dashboard page or post editor content is not showing but front end data is showing properly -

How to get the ip address of VM and use it to configure SSH connection dynamically in Ansible -

javascript - Get parameter of GET request -