Method process

aleph/worker.py:138–143

(self, blocking=True)

        super().on_signal(signal, _)

    def process(self, blocking=True):
        if blocking:
            with app.app_context():
                self.process_blocking()
        else:
            self.process_nonblocking()

    def periodic(self):
        with app.app_context():