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

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
integrate celery with flask URL#configuring-celery .