(self, task, *args, **kwargs)
| 910 | return self |
| 911 | |
| 912 | def error(self, task, *args, **kwargs): |
| 913 | if self.on_error: |
| 914 | self.on_error.error(task, *args, **kwargs) |
| 915 | else: |
| 916 | if isinstance(task, Task): |
| 917 | if args: task.extend_data(args) |
| 918 | if kwargs: task.extend_data(kwargs) |
| 919 | else: |
| 920 | task = task.s(*args, **kwargs) |
| 921 | self.on_error = task |
| 922 | return self |
| 923 | |
| 924 | def execute(self): |
| 925 | # Implementation provided by subclass, see: TaskWrapper.create_task(). |