chore: replace json.loads() with the internal impit method Response.json()

src/apify_client/_utils.py

@@ -262,7 +262,7 @@ def maybe_parse_response(response: Response) -> Any:
 
     try:
         if is_content_type_json(content_type):
-            response_data = jsonlib.loads(response.text)
+            response_data = response.json()
         elif is_content_type_xml(content_type) or is_content_type_text(content_type):
             response_data = response.text
         else:

src/apify_client/clients/base/actor_job_base_client.py

@@ -1,7 +1,6 @@
 from __future__ import annotations
 
 import asyncio
-import json as jsonlib
 import math
 import time
 from datetime import datetime, timezone
@@ -38,7 +37,7 @@ def _wait_for_finish(self, wait_secs: int | None = None) -> dict | None:
                     method='GET',
                     params=self._params(waitForFinish=wait_for_finish),
                 )
-                job = parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+                job = parse_date_fields(pluck_data(response.json()))
 
                 seconds_elapsed = math.floor((datetime.now(timezone.utc) - started_at).total_seconds())
                 if ActorJobStatus(job['status']).is_terminal or (
@@ -69,7 +68,7 @@ def _abort(self, *, gracefully: bool | None = None) -> dict:
             method='POST',
             params=self._params(gracefully=gracefully),
         )
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
 
 class ActorJobBaseClientAsync(ResourceClientAsync):
@@ -92,7 +91,7 @@ async def _wait_for_finish(self, wait_secs: int | None = None) -> dict | None:
                     method='GET',
                     params=self._params(waitForFinish=wait_for_finish),
                 )
-                job = parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+                job = parse_date_fields(pluck_data(response.json()))
 
                 seconds_elapsed = math.floor((datetime.now(timezone.utc) - started_at).total_seconds())
                 if ActorJobStatus(job['status']).is_terminal or (
@@ -123,4 +122,4 @@ async def _abort(self, *, gracefully: bool | None = None) -> dict:
             method='POST',
             params=self._params(gracefully=gracefully),
         )
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))

src/apify_client/clients/base/resource_client.py

@@ -1,7 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
-
 from apify_client._utils import catch_not_found_or_throw, parse_date_fields, pluck_data
 from apify_client.clients.base.base_client import BaseClient, BaseClientAsync
 from apify_client.errors import ApifyApiError
@@ -19,7 +17,7 @@ def _get(self, timeout_secs: int | None = None) -> dict | None:
                 timeout_secs=timeout_secs,
             )
 
-            return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+            return parse_date_fields(pluck_data(response.json()))
 
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
@@ -35,7 +33,7 @@ def _update(self, updated_fields: dict, timeout_secs: int | None = None) -> dict
             timeout_secs=timeout_secs,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def _delete(self, timeout_secs: int | None = None) -> None:
         try:
@@ -62,7 +60,7 @@ async def _get(self, timeout_secs: int | None = None) -> dict | None:
                 timeout_secs=timeout_secs,
             )
 
-            return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+            return parse_date_fields(pluck_data(response.json()))
 
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
@@ -78,7 +76,7 @@ async def _update(self, updated_fields: dict, timeout_secs: int | None = None) -
             timeout_secs=timeout_secs,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     async def _delete(self, timeout_secs: int | None = None) -> None:
         try:

src/apify_client/clients/base/resource_collection_client.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
 from typing import Any, Generic, TypeVar
 
 from apify_client._utils import parse_date_fields, pluck_data
@@ -50,7 +49,7 @@ def _list(self, **kwargs: Any) -> ListPage:
             params=self._params(**kwargs),
         )
 
-        return ListPage(parse_date_fields(pluck_data(jsonlib.loads(response.text))))
+        return ListPage(parse_date_fields(pluck_data(response.json())))
 
     def _create(self, resource: dict) -> dict:
         response = self.http_client.call(
@@ -60,7 +59,7 @@ def _create(self, resource: dict) -> dict:
             json=resource,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def _get_or_create(self, name: str | None = None, resource: dict | None = None) -> dict:
         response = self.http_client.call(
@@ -70,7 +69,7 @@ def _get_or_create(self, name: str | None = None, resource: dict | None = None)
             json=resource,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
 
 class ResourceCollectionClientAsync(BaseClientAsync):
@@ -83,7 +82,7 @@ async def _list(self, **kwargs: Any) -> ListPage:
             params=self._params(**kwargs),
         )
 
-        return ListPage(parse_date_fields(pluck_data(jsonlib.loads(response.text))))
+        return ListPage(parse_date_fields(pluck_data(response.json())))
 
     async def _create(self, resource: dict) -> dict:
         response = await self.http_client.call(
@@ -93,7 +92,7 @@ async def _create(self, resource: dict) -> dict:
             json=resource,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     async def _get_or_create(
         self,
@@ -107,4 +106,4 @@ async def _get_or_create(
             json=resource,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))

src/apify_client/clients/resource_clients/actor.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
 from typing import TYPE_CHECKING, Any, Literal
 
 from apify_client._utils import (
@@ -286,7 +285,7 @@ def start(
             params=request_params,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def call(
         self,
@@ -404,7 +403,7 @@ def build(
             params=request_params,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def builds(self) -> BuildCollectionClient:
         """Retrieve a client for the builds of this Actor."""
@@ -435,7 +434,7 @@ async def default_build(
         )
 
         response = self.http_client.call(url=self._url('builds/default'), method='GET', params=request_params)
-        data = pluck_data(jsonlib.loads(response.text))
+        data = pluck_data(response.json())
 
         return BuildClient(
             base_url=self.base_url,
@@ -706,7 +705,7 @@ async def start(
             params=request_params,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     async def call(
         self,
@@ -828,7 +827,7 @@ async def build(
             params=request_params,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def builds(self) -> BuildCollectionClientAsync:
         """Retrieve a client for the builds of this Actor."""
@@ -863,7 +862,7 @@ async def default_build(
             method='GET',
             params=request_params,
         )
-        data = pluck_data(jsonlib.loads(response.text))
+        data = pluck_data(response.json())
 
         return BuildClientAsync(
             base_url=self.base_url,

src/apify_client/clients/resource_clients/build.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
 from typing import Any
 
 from apify_client.clients.base import ActorJobBaseClient, ActorJobBaseClientAsync
@@ -54,7 +53,7 @@ def get_open_api_definition(self) -> dict | None:
             method='GET',
         )
 
-        response_data: dict = jsonlib.loads(response.text)
+        response_data: dict = response.json()
 
         return response_data
 
@@ -130,7 +129,7 @@ async def get_open_api_definition(self) -> dict | None:
             method='GET',
         )
 
-        response_data: dict = jsonlib.loads(response.text)
+        response_data: dict = response.json()
 
         return response_data
 

src/apify_client/clients/resource_clients/dataset.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
 import warnings
 from contextlib import asynccontextmanager, contextmanager
 from typing import TYPE_CHECKING, Any
@@ -141,7 +140,7 @@ def list_items(
             params=request_params,
         )
 
-        data = jsonlib.loads(response.text)
+        data = response.json()
 
         return ListPage(
             {
@@ -559,7 +558,7 @@ def get_statistics(self) -> dict | None:
                 params=self._params(),
                 timeout_secs=_SMALL_TIMEOUT,
             )
-            return pluck_data(jsonlib.loads(response.text))
+            return pluck_data(response.json())
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
 
@@ -739,7 +738,7 @@ async def list_items(
             params=request_params,
         )
 
-        data = jsonlib.loads(response.text)
+        data = response.json()
 
         return ListPage(
             {
@@ -1066,7 +1065,7 @@ async def get_statistics(self) -> dict | None:
                 params=self._params(),
                 timeout_secs=_SMALL_TIMEOUT,
             )
-            return pluck_data(jsonlib.loads(response.text))
+            return pluck_data(response.json())
         except ApifyApiError as exc:
             catch_not_found_or_throw(exc)
 

src/apify_client/clients/resource_clients/key_value_store.py

@@ -1,6 +1,5 @@
 from __future__ import annotations
 
-import json as jsonlib
 from contextlib import asynccontextmanager, contextmanager
 from http import HTTPStatus
 from typing import TYPE_CHECKING, Any
@@ -106,7 +105,7 @@ def list_keys(
             timeout_secs=_MEDIUM_TIMEOUT,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     def get_record(self, key: str) -> dict | None:
         """Retrieve the given record from the key-value store.
@@ -424,7 +423,7 @@ async def list_keys(
             timeout_secs=_MEDIUM_TIMEOUT,
         )
 
-        return parse_date_fields(pluck_data(jsonlib.loads(response.text)))
+        return parse_date_fields(pluck_data(response.json()))
 
     async def get_record(self, key: str) -> dict | None:
         """Retrieve the given record from the key-value store.