@@ -38,10 +38,10 @@ async def main():
3838
3939import logging
4040import warnings
41- from collections .abc import AsyncIterator , Awaitable , Callable , Iterator
41+ from collections .abc import AsyncIterator , Awaitable , Callable , Iterator , Mapping
4242from contextlib import AbstractAsyncContextManager , AsyncExitStack , asynccontextmanager , contextmanager
4343from importlib .metadata import version as importlib_version
44- from typing import Any , Generic
44+ from typing import Any , Generic , cast
4545
4646import anyio
4747from anyio .streams .memory import MemoryObjectReceiveStream , MemoryObjectSendStream
@@ -79,8 +79,8 @@ def _bind_request_auth_context(request_context: Any) -> Iterator[None]:
7979 """Rebind auth context from the current transport request while handling a message."""
8080 authenticated_user = None
8181 scope = getattr (request_context , "scope" , None )
82- if isinstance (scope , dict ):
83- scope_user = scope .get ("user" )
82+ if isinstance (scope , Mapping ):
83+ scope_user = cast ( Mapping [ str , object ], scope ) .get ("user" )
8484 if isinstance (scope_user , AuthenticatedUser ):
8585 authenticated_user = scope_user
8686
0 commit comments