@@ -66,12 +66,16 @@ class HTTPClient:
6666 """
6767
6868 def __init__ (
69- self , token : str , * , session : aiohttp .ClientSession = None , ** kwargs : Any
69+ self ,
70+ token : str ,
71+ * ,
72+ session : Optional [aiohttp .ClientSession ] = None ,
73+ ** kwargs : Any ,
7074 ) -> None :
7175 self .BASE = "https://top.gg/api"
7276 self .token = token
7377 self ._own_session = session is None
74- self .session = session or aiohttp .ClientSession (** kwargs )
78+ self .session : aiohttp . ClientSession = session or aiohttp .ClientSession (** kwargs )
7579 self .global_rate_limiter = AsyncRateLimiter (
7680 max_calls = 99 , period = 1 , callback = _rate_limit_handler
7781 )
@@ -110,7 +114,7 @@ async def request(self, method: str, endpoint: str, **kwargs: Any) -> dict:
110114 kwargs ["headers" ] = headers
111115
112116 for _ in range (2 ):
113- async with rate_limiters :
117+ async with rate_limiters : # type: ignore
114118 async with self .session .request (method , url , ** kwargs ) as resp :
115119 _LOGGER .debug (
116120 "%s %s with %s has returned %s" ,
@@ -129,7 +133,7 @@ async def request(self, method: str, endpoint: str, **kwargs: Any) -> dict:
129133 fmt = "We are being ratelimited. Retrying in %.2f seconds (%.3f minutes)."
130134
131135 # sleep a bit
132- retry_after = float (resp .headers . get ( "Retry-After" ) )
136+ retry_after = float (resp .headers [ "Retry-After" ] )
133137 mins = retry_after / 60
134138 _LOGGER .warning (fmt , retry_after , mins )
135139
0 commit comments