def my_task():
    session = db.create_scoped_session()
session.add(User(id=13, value='random string'))
session.commit()
return
Соединение закрывается, когда событие SQLAlchemy запускает задачу Celery.