##// END OF EJS Templates
Another better solution for establishing connection with messaging broker in celery....
Another better solution for establishing connection with messaging broker in celery. This one doesn't require celeryconfig.py

File last commit:

r612:79457e03 merge default
r1003:9037456b beta
Show More
meta.py
26 lines | 767 B | text/x-python | PythonLexer
"""SQLAlchemy Metadata and Session object"""
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import scoped_session, sessionmaker
from rhodecode.model import caching_query
from beaker import cache
# Beaker CacheManager. A home base for cache configurations.
cache_manager = cache.CacheManager()
__all__ = ['Base', 'Session']
#
# SQLAlchemy session manager. Updated by model.init_model()
#
Session = scoped_session(
sessionmaker(
query_cls=caching_query.query_callable(cache_manager)
)
)
# The declarative Base
Base = declarative_base()
#For another db...
#Base2 = declarative_base()
#to use cache use this in query
#.options(FromCache("sqlalchemy_cache_type", "cachekey"))