LNT: Run pre-commit. [skip ci]

async_retriever/_utils.py

@@ -95,7 +95,7 @@ async def stream_session(
 ) -> None:
     """Stream the response to a file."""
     async with session(url, **s_kwds) as response:
-        if response.status != 200:
+        if response.status != 200:  # noqa: PLR2004
             raise ServiceError(await response.text(), str(response.url))
         with filepath.open("wb") as fd:
             if chunk_size is None:

async_retriever/async_retriever.py

@@ -232,7 +232,7 @@ async def async_session_with_cache(
             utils.retriever(uid, url, kwds, request_func, read, r_kwds, raise_status)
             for uid, url, kwds in url_kwds
         )
-        return await asyncio.gather(*tasks)  # pyright: ignore[reportGeneralTypeIssues]
+        return await asyncio.gather(*tasks)  # pyright: ignore[reportReturnType]
 
 
 async def async_session_without_cache(
@@ -276,7 +276,7 @@ async def async_session_without_cache(
             utils.retriever(uid, url, kwds, request_func, read, r_kwds, raise_status)
             for uid, url, kwds in url_kwds
         )
-        return await asyncio.gather(*tasks)  # pyright: ignore[reportGeneralTypeIssues]
+        return await asyncio.gather(*tasks)  # pyright: ignore[reportReturnType]
 
 
 @overload
@@ -391,7 +391,7 @@ def retrieve(
     ...     ]
     ... )
     >>> resp = ar.retrieve(urls, "text", request_kwds=kwds)
-    >>> resp[0].split('\n')[-2].split('\t')[1]
+    >>> resp[0].split("\n")[-2].split("\t")[1]
     '01646500'
     """
     inp = BaseRetriever(
@@ -496,7 +496,7 @@ def retrieve_text(
     ...     ]
     ... )
     >>> resp = ar.retrieve_text(urls, kwds)
-    >>> resp[0].split('\n')[-2].split('\t')[1]
+    >>> resp[0].split("\n")[-2].split("\t")[1]
     '01646500'
     """
     return retrieve(