Flask Framework Cookbook - Second Edition

How to do it...

Follow these steps to understand Celery's integration with the Flask application:

1. First, we need to do a bit of configuration in the application's configuration, that is, my_app/__init__.py:

from celery import Celery 
 
app.config.update( 
    CELERY_BROKER_URL='redis://localhost:6379', 
    CELERY_RESULT_BACKEND='redis://localhost:6379' 
) 
 
def make_celery(app): 
    celery = Celery( 
        app.import_name, broker=app.config['CELERY_BROKER_URL'] 
    ) 
    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 

The preceding snippet comes directly from the Flask website ...