UPD. проблема найдена
кто шарит в
aiopg и
sqlalchemy, help!
не получается произвести транзакцию
не обновляется база данных
where = accounts.c.id == donor_id
donor_query = accounts.select().where(where)
donor = await (await conn.execute(donor_query)).fetchone()
where = accounts.c.id == recipient_id
recipient_query = accounts.select().where(where)
recipient = await (await conn.execute(recipient_query)).fetchone()
donor_amount = donor.amount - amount
recipient_amount = recipient.amount + amount
async with conn.begin():
await conn.execute(sa.update(accounts).values({'amount': donor_amount}).where(
# donor_query <-- ошибка # было
accounts.c.id == donor_id # стало
))
await conn.execute(sa.update(accounts).values({'amount': recipient_amount}).where(
# recipient_query <-- ошибка # было
accounts.c.id == recipient_id # стало
))
что не так?
UPD. проблема найдена
