async_engine = create_async_engine(postgres_url)
await proceed_schemas(async_engine, BaseModel.metadata)
session_maker = get_session_maker(async_engine)
wallet = requests.get(url = f'{base_url}{ticker}/create/', params=query).json()
print(wallet)
print(user_id)
async with session_maker() as session:
async with session.begin():
result = await session.execute(select(User).where(User.user_id == user_id))
user: User = result.one_or_none()
user.unique_wallet = wallet.get('address_out')
user.address_wallet = wallet.get('address_in')
await session.merge(user)
return wallet.get('address_in')
1. Почему ты просишь явно None и потом никак эту ситуация не валидируешь? 2. Пробовал с дебаггером запускать и такой же запрос в бд пульнуть?
с дебаггером user = None
А в базе он есть?
Обсуждают сегодня