We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d32692b commit af58a10Copy full SHA for af58a10
1 file changed
sqlalchemy_database/_abc_async_database.py
@@ -92,6 +92,9 @@ async def asgi_dispatch(self, request, call_next):
92
app.add_middleware(BaseHTTPMiddleware, dispatch=db.asgi_dispatch)
93
```
94
"""
95
+ if request.scope.get("__sqlalchemy_database__", False):
96
+ return await call_next(request)
97
# bind session to request
98
async with self.__call__(scope=id(request.scope)):
99
+ request.scope["__sqlalchemy_database__"] = self
100
return await call_next(request)
0 commit comments