The body of the task executed by workers.
(self, *args, **kwargs)
| 443 | return (_unpickle_task_v2, (self.name, mod), None) |
| 444 | |
| 445 | def run(self, *args, **kwargs): |
| 446 | """The body of the task executed by workers.""" |
| 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) |
no outgoing calls
no test coverage detected