Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from celery import Celery
- from app import app
- from app.models import Domain
- from flask.ext.sqlalchemy import SQLAlchemy
- 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
- celery = make_celery(app)
- db = SQLAlchemy(app)
- domains = db.session.query(Domain).all()
- @celery.task
- def cel_log(*args, **kwargs):
- print kwargs
- return True
- site-packages/celery/bin/base.py", line 473, in setup_app_from_commandline
- user_preload = tuple(self.app.user_options['preload'] or ())
- AttributeError: 'Flask' object has no attribute 'user_options'
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement