(self, args=None, kwargs=None,
propagate=True, body=None, **options)
| 2156 | return self.run(tasks, body, args, task_id=task_id, kwargs=kwargs, **merged_options) |
| 2157 | |
| 2158 | def apply(self, args=None, kwargs=None, |
| 2159 | propagate=True, body=None, **options): |
| 2160 | args = args if args else () |
| 2161 | kwargs = kwargs if kwargs else {} |
| 2162 | body = self.body if body is None else body |
| 2163 | tasks = (self.tasks.clone() if isinstance(self.tasks, group) |
| 2164 | else group(self.tasks, app=self.app)) |
| 2165 | return body.apply( |
| 2166 | args=(tasks.apply(args, kwargs).get(propagate=propagate),), |
| 2167 | ) |
| 2168 | |
| 2169 | @classmethod |
| 2170 | def _descend(cls, sig_obj): |
no test coverage detected