Method run

celery/app/task.py:445–447

The body of the task executed by workers.

(self, *args, **kwargs)

        return (_unpickle_task_v2, (self.name, mod), None)

    def run(self, *args, **kwargs):
        class="st">""class="st">"The body of the task executed by workers."class="st">""
        raise NotImplementedError(&class="cm">#x27;Tasks must define the run method.')

    def start_strategy(self, app, consumer, **kwargs):
        return instantiate(self.Strategy, self, app, consumer, **kwargs)