create_celery.py

from celery import Celery 


def create_app(app):
    celery = Celery(__name__, broker='amqp://user:password@localhost/vhost')
    celery.conf.update(app.config)
    TaskBase = celery.Task

    class ContextTask(TaskBase):
        abstract = True

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

    celery.Task = ContextTask

    return celery