(self, tasks, callback)
| 1167 | |
| 1168 | class chord(object): |
| 1169 | def __init__(self, tasks, callback): |
| 1170 | if isinstance(callback, TaskWrapper): |
| 1171 | callback = callback.s() |
| 1172 | self.tasks = tasks |
| 1173 | self.callback = callback |
| 1174 | |
| 1175 | def then(self, task, *args, **kwargs): |
| 1176 | self.callback.then(task, *args, **kwargs) |