Method on_crash

celery/utils/threads.py:57–59

(self, msg, *fmt, **kwargs)

        raise NotImplementedError()

    def on_crash(self, msg, *fmt, **kwargs):
        print(msg.format(*fmt), file=sys.stderr)
        traceback.print_exc(None, sys.stderr)

    def run(self):
        body = self.body