Подключение к БД в SQLAlchemyJobStore

Всем привет! Разрабатываю высоконагруженного ТГ-бота. Одна из функций - планировщик с отправкой сообщения по указанному времени. В данный момент у меня наблюдается следующая проблема: Я хочу сделать так, чтобы задачи имели свойство отсроченного выполнения, а также могли выполняться, даже если я перезапускаю бота. Для этого в качестве хранилища выбрал SQLAlchemyJobStore, однако загвоздка в том, что подключение к БД у класса может быть ТОЛЬКО синхронным. Подскажите, как мне выкрутится из данной ситуации, сохранив полный и функционал и работоспособность при высоконагруженных системах?

scheduler_motivate = ContextSchedulerDecorator(AsyncIOScheduler(
    jobstores={'default': SQLAlchemyJobStore(engine=db.sync_engine)}
))
scheduler_motivate.ctx.add_instance(bot, declared_class=Bot)
scheduler_motivate.start()

Ответы (0 шт):