Celery¶
API¶
-
twopi_flask_utils.celery.
create_celery
(name, config_obj, inject_version=True, **kwargs)¶ Creates a celery app.
Parameters: - config_obj – The configuration object to initiaze with
- inject_version –
- bool: Whether or not to inject the application’s
- version number. Attempts to get version number
- kwargs – Other arguments to pass to the
Celery
instantiation.
Returns: An initialized celery application.
-
twopi_flask_utils.celery.
create_db_session
(celery)¶ Creates an SQLA Database scoped session. Requires SQLAlchemy.
Uses
SQLALCHEMY_DATABASE_URI
andSQLALCHEMY_POOL_RECYCLE
to create an apropriate engine.If you are using MySQL and
SQLALCHEMY_POOL_RECYCLE
is not specified, you’ll have a bad time - this is required, as MySQL kills old sessions.Parameters: celery – The celery application to create the app on Returns: A SQLAlchemy scoped_session instance.