DBSession = scoped_session(sessionmaker(autoflush=True, autocommit=False,
    bind=db_engine))


class MTWorker(object):

    def __init__(self, worker_count=5):
        self.task_queue = Queue()
Правильная обработка сеанса SQLAlchemy в многопоточных приложениях