Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 6 additions & 5 deletions src/oxylabs/internal/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
import requests
import aiohttp
import asyncio
from typing import Union
from platform import python_version, architecture
from oxylabs._version import __version__
from oxylabs.utils.defaults import ASYNC_BASE_URL, SYNC_BASE_URL
Expand Down Expand Up @@ -68,7 +69,7 @@ def get_response(self, payload:dict, config:dict) -> dict:

return self._get_http_response(payload, "POST", config)

def _get_http_response(self, payload: dict, method: str, config: dict) -> dict | None:
def _get_http_response(self, payload: dict, method: str, config: dict) -> Union[dict, None]:
"""
Sends an HTTP request to the specified URL with the given payload
and method.
Expand Down Expand Up @@ -136,7 +137,7 @@ def __init__(self, api_credentials: APICredentials, **kwargs) -> None:
self._session = None
self._requests = 0

async def get_response(self, payload: dict, config: dict) -> dict | None:
async def get_response(self, payload: dict, config: dict) -> Union[dict, None]:
"""
Processes the payload asynchronously and fetches the response.

Expand Down Expand Up @@ -175,7 +176,7 @@ async def _get_job_id(
payload: dict,
user_session: aiohttp.ClientSession,
request_timeout: int,
) -> str | None:
) -> Union[str, None]:
try:
async with user_session.post(
self._base_url,
Expand Down Expand Up @@ -232,7 +233,7 @@ async def _poll_job_status(

async def _get_http_response(
self, job_id: str, user_session: aiohttp.ClientSession
) -> dict | None:
) -> Union[dict, None]:
"""
Retrieves the HTTP response for a given job ID.

Expand Down Expand Up @@ -291,4 +292,4 @@ async def _execute_with_timeout(
logger.error("Job did not complete successfully")

result = await self._get_http_response(job_id, user_session)
return result
return result