(self, app, consumer, **kwargs)
| 447 | raise NotImplementedError('Tasks must define the run method.') |
| 448 | |
| 449 | def start_strategy(self, app, consumer, **kwargs): |
| 450 | return instantiate(self.Strategy, self, app, consumer, **kwargs) |
| 451 | |
| 452 | def delay(self, *args, **kwargs): |
| 453 | """Star argument version of :meth:`apply_async`. |