We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 23aa724 commit b5792cdCopy full SHA for b5792cd
app/database/async/db_op.py
@@ -20,14 +20,15 @@ async def add_user(
20
"""
21
add new user
22
23
- db_user = UserModel(username, password)
24
async with self.get_async_session() as session:
25
- async with session.begin():
26
- try:
+ try:
+ async with session.begin():
+ db_user = UserModel(username, password)
27
session.add(db_user)
28
await session.flush() # refresh own primary key
29
session.expunge(db_user) # release data
30
# begin() context will auto commit trancastion
31
- except SQLAlchemyError as sql_ex:
32
- raise sql_ex
33
- return db_user
+ return db_user
+ except SQLAlchemyError as sql_ex:
+ raise sql_ex
34
+
0 commit comments