| 1150 | |
| 1151 | |
| 1152 | class group(object): |
| 1153 | def __init__(self, tasks): |
| 1154 | self.tasks = tasks |
| 1155 | |
| 1156 | def then(self, task, *args, **kwargs): |
| 1157 | if not isinstance(task, Task): |
| 1158 | task = task.s(*args, **kwargs) |
| 1159 | return chord(self.tasks, task) |
| 1160 | |
| 1161 | def error(self, *args, **kwargs): |
| 1162 | # Apply error handler to all tasks. |
| 1163 | for task in self.tasks: |
| 1164 | task.error(*args, **kwargs) |
| 1165 | return self |
| 1166 | |
| 1167 | |
| 1168 | class chord(object): |
no outgoing calls
searching dependent graphs…