(task_self)
| 573 | |
| 574 | @manager.app.task(bind=True) |
| 575 | def parent_task(task_self): |
| 576 | # Call child task via apply() |
| 577 | child_data = child_task.apply().get() |
| 578 | parent_data = { |
| 579 | 'task_id': task_self.request.id, |
| 580 | 'parent_id': task_self.request.parent_id, |
| 581 | 'root_id': task_self.request.root_id, |
| 582 | 'name': 'parent_task', |
| 583 | 'child_data': child_data |
| 584 | } |
| 585 | return parent_data |
| 586 | |
| 587 | result = parent_task.apply() |
| 588 |