async.py

#project.async
from celery import Celery

celery = Celery(autofinalize=False)


def configure_celery(flask_app):
    #...set celery up
    celery.config_from_object(app.config)
    
    class ContextTask(celery.Task):
        abstract = True
        def __call__(self, *args, **kwargs):
            with flask_app.app_context():
                return super(ContextTask, self).__call__(*args, **kwargs)
    celery.Task = ContextTask
    celery.finalize()

#project.__init__
create_app(*kwargs):
    
    app = Flaks(__name__)
    db.init_app(app)
    
    configure_celery(flask_app)

#project.tasks
from project.async import celery
    
@celery.task
def add(x, y):
    x + y