app/celery/celery.py

from celery import Celery


class NotifyCelery(Celery):

    def init_app(self, app):
        super().__init__(app.import_name, broker=app.config['BROKER_URL'])
        self.conf.update(app.config)
        TaskBase = self.Task

        class ContextTask(TaskBase):
            abstract = True

            def __call__(self, *args, **kwargs):
                with app.app_context():
                    return TaskBase.__call__(self, *args, **kwargs)
        self.Task = ContextTask
Celery tests 2016-02-09 13:31:45 +00:00			`from celery import Celery`
hacked celery4.0.2 in. Runs and works - note though this version of master I branched had split head on sqlalchemey. This needs a new master merge to fix 2017-06-01 14:32:19 +01:00
Celery tests 2016-02-09 13:31:45 +00:00
			`class NotifyCelery(Celery):`
Finished celery refactor - set up config for queue prefix LEO notes: Also made sure the Test BROKER_URL is preserved so that tests warn you when celery isn't mocked out 2017-06-09 16:20:02 +01:00
Revert celery4 Revert the following three pull requests: https://github.com/alphagov/notifications-api/pull/1085 https://github.com/alphagov/notifications-api/pull/1086 https://github.com/alphagov/notifications-api/pull/1088 celery 4.0.2 looked promising, however, on staging under mild load (5/sec api calls) the performance was actually worse than 3.1.25 2017-07-19 13:50:29 +01:00			`def init_app(self, app):`
			`super().__init__(app.import_name, broker=app.config['BROKER_URL'])`
			`self.conf.update(app.config)`
Celery tests 2016-02-09 13:31:45 +00:00			`TaskBase = self.Task`

			`class ContextTask(TaskBase):`
			`abstract = True`

			`def __call__(self, args, *kwargs):`
			`with app.app_context():`
			`return TaskBase.__call__(self, args, *kwargs)`
			`self.Task = ContextTask`