This document describes the current stable version of Celery (5.6). For development docs, go here.

celery.backends.database.session

SQLAlchemy session.

class celery.backends.database.session.SessionManager

Manage SQLAlchemy sessions.

create_session(dburi, short_lived_sessions=False, **kwargs)

get_engine(dburi, **kwargs)

invalidate(dburi)

Dispose cached engine/session state for a database URI.

prepare_models(engine)

session_factory(dburi, **kwargs)