littlefish/celeryutil.py
def init_celery(app, celery):
    """
    Initialise Celery and set up logging

    :param app: Flask app
    :param celery: Celery instance
    """
    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 init_celery(app, celery):
    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 init_celery ( app , celery ) : 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
Initialise Celery and set up logging

    :param app: Flask app
    :param celery: Celery instance
Initialise Celery and set up logging