Celery worker for project

celery_worker.py

from celery import Celery
from celery.schedules import crontab
from app import create_app
from app.tasks import log


def create_celery(app):
    celery = Celery(app.import_name,
                    backend=app.config['CELERY_RESULT_BACKEND'],
                    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


flask_app = create_app()
celery = create_celery(flask_app)


@celery.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    # period task executes every 2.5 seconds
    sender.add_periodic_task(48400, log, name='Log Users')

    # periodic task executes on crontab schedule
    sender.add_periodic_task(
        crontab(hour=0, minute=2),
        log,
        name='Run the log'
    )