from factory import create_celery_app
from celery.signals import task_prerun
from flask import g
from extensions import db

celery = create_celery_app()

@task_prerun.connect
def celery_prerun(*args, **kwargs):
    #print g
    with celery.app.app_context():
    #   # use g.db
        print db
        print g

#@celery.task(base=celery.Task)
@celery.task()
def do_some_stuff():
    print db
    print g

# run with: celery.exe worker -A tasks