summaryrefslogtreecommitdiff
path: root/searx/network/network.py
diff options
context:
space:
mode:
Diffstat (limited to 'searx/network/network.py')
-rw-r--r--searx/network/network.py8
1 files changed, 6 insertions, 2 deletions
diff --git a/searx/network/network.py b/searx/network/network.py
index ff02d447a..84aaebe34 100644
--- a/searx/network/network.py
+++ b/searx/network/network.py
@@ -1,7 +1,9 @@
# SPDX-License-Identifier: AGPL-3.0-or-later
# pylint: disable=global-statement
# pylint: disable=missing-module-docstring, missing-class-docstring
+from __future__ import annotations
+import typing
import atexit
import asyncio
import ipaddress
@@ -11,6 +13,7 @@ from typing import Dict
import httpx
from searx import logger, searx_debug
+from searx.extended_types import SXNG_Response
from .client import new_client, get_loop, AsyncHTTPTransportNoHttp
from .raise_for_httperror import raise_for_httperror
@@ -233,8 +236,9 @@ class Network:
del kwargs['raise_for_httperror']
return do_raise_for_httperror
- def patch_response(self, response, do_raise_for_httperror):
+ def patch_response(self, response, do_raise_for_httperror) -> SXNG_Response:
if isinstance(response, httpx.Response):
+ response = typing.cast(SXNG_Response, response)
# requests compatibility (response is not streamed)
# see also https://www.python-httpx.org/compatibility/#checking-for-4xx5xx-responses
response.ok = not response.is_error
@@ -258,7 +262,7 @@ class Network:
return False
return True
- async def call_client(self, stream, method, url, **kwargs):
+ async def call_client(self, stream, method, url, **kwargs) -> SXNG_Response:
retries = self.retries
was_disconnected = False
do_raise_for_httperror = Network.extract_do_raise_for_httperror(kwargs)