T
Всем привет! Запускаю фоновую задачу из приложения flask на celery брокер на redis. При изменении кода задачи, при запуске отрабатывает старая версия. Подскажите, как корректно обновлять задачу? Может кеш какой где?
А селери перезапускал?
Size: a a a
2020 May 30
T
один раз поставил и счастлив
Зачем?
T
один раз поставил и счастлив
Какую задачу он решает, которую нелзя для решить стандартными средствами без него?
SN
просто запустить одновременно два разных приложения
Простой flask server и лонгполл бота
Простой flask server и лонгполл бота
KK
А селери перезапускал?
Flask перезапускал только
T
просто запустить одновременно два разных приложения
Простой flask server и лонгполл бота
Простой flask server и лонгполл бота
А зачем для этого супервизор ставить?
SN
А автоконнект тебе не показать?
Тебе надо фласковые before_request и teardown_appcontext скорее всего. Могу путать, но примерно так
Тебе надо фласковые before_request и teardown_appcontext скорее всего. Могу путать, но примерно так
тут такой вопрос..А если у меня коннекшены запрятаны в self свойства репозиториев
Можно ли как-то отрубить их у репозиториев при teardown_request
Можно ли как-то отрубить их у репозиториев при teardown_request
T
Flask перезапускал только
Ну вот и ответ
T
тут такой вопрос..А если у меня коннекшены запрятаны в self свойства репозиториев
Можно ли как-то отрубить их у репозиториев при teardown_request
Можно ли как-то отрубить их у репозиториев при teardown_request
Я бы просто пересоздавал репозиторий на каждый запрос
SN
хм
Хорошая идея, спасибо
Хорошая идея, спасибо
T
тут такой вопрос..А если у меня коннекшены запрятаны в self свойства репозиториев
Можно ли как-то отрубить их у репозиториев при teardown_request
Можно ли как-то отрубить их у репозиториев при teardown_request
Тебе надо чтобы под каждый реквест был свой Коннект. У тебя могут два реквеста параллельно обрабатываться.
SN
получается как-то так?
@app.before_request
def create_services():
guild_service = services.guild.GuildService()
mailing_service = services.mailing.MailingService()
admin_service = services.admin.AdminService()
SN
а удалять сервисы в @app.teardown_request нужно?
T
Ага, только сервисы в flask.g положи
SN
Ага, только сервисы в flask.g положи
?
T
а удалять сервисы в @app.teardown_request нужно?
Нужно коннект закрыть, так как сервисы без него не живут, видимо придется удалять
T
Ну вьюхи же должны как-то получить к ним доступ
SN
Нужно коннект закрыть, так как сервисы без него не живут, видимо придется удалять
del ?
SN
пойдет?
T
del ?
Ну вроде g сам очистится, главное сессию закрой