Skip to content

Commit 78dbe65

Browse files
committed
fix unnecessary magic method
1 parent 345c32e commit 78dbe65

File tree

2 files changed

+6
-16
lines changed

2 files changed

+6
-16
lines changed

fastapi_async_sqlalchemy/exceptions.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ def __init__(self):
88
a context manager e.g.:
99
1010
with db():
11-
db.session.query(User).all()
11+
await db.session.execute(foo.select()).fetchall()
1212
"""
1313

1414
super().__init__(msg)

fastapi_async_sqlalchemy/middleware.py

Lines changed: 5 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -74,29 +74,19 @@ async def __anext__(self):
7474
async def __aenter__(self):
7575
if not isinstance(_Session, sessionmaker):
7676
raise SessionNotInitialisedError
77+
7778
self.token = _session.set(_Session(**self.session_args))
7879
return self.token
7980

8081
async def __aexit__(self, exc_type, exc_value, traceback):
81-
sess = _session.get()
82-
if exc_type is not None:
83-
await sess.rollback()
84-
85-
if self.commit_on_exit:
86-
await sess.commit()
87-
88-
await sess.close()
89-
_session.reset(self.token)
90-
91-
def __exit__(self, exc_type, exc_value, traceback):
92-
sess = _session.get()
82+
session = _session.get()
9383
if exc_type is not None:
94-
sess.rollback()
84+
await session.rollback()
9585

9686
if self.commit_on_exit:
97-
sess.commit()
87+
await session.commit()
9888

99-
sess.close()
89+
await session.close()
10090
_session.reset(self.token)
10191

10292

0 commit comments

Comments
 (0)