chore(deps): lock file maintenance

src/apify/storage_clients/_apify/_dataset_client.py

@@ -2,6 +2,7 @@
 
 import asyncio
 import json
+from collections.abc import Sequence
 from logging import getLogger
 from typing import TYPE_CHECKING
 
@@ -16,7 +17,7 @@
 from apify.storage_clients._ppe_dataset_mixin import DatasetClientPpeMixin
 
 if TYPE_CHECKING:
-    from collections.abc import AsyncIterator, Mapping, Sequence
+    from collections.abc import AsyncIterator, Mapping
 
     from apify_client._resource_clients import DatasetClientAsync
     from crawlee._types import JsonSerializable
@@ -134,7 +135,7 @@ async def push_data(self, data: Sequence[Mapping[str, JsonSerializable]] | Mappi
         # Pushing mutates no client state - `push_items` is a stateless API call - so concurrent pushes only need
         # the charge lock, which keeps the limit reservation and the charge atomic for pay-per-event runs.
         async with charge_lock_if_charging():
-            items = data if self._is_sequence_of_items(data) else [data]
+            items = data if isinstance(data, Sequence) else [data]
             if not items:
                 return
             limit = self._compute_limit_for_push(len(items))

src/apify/storage_clients/_file_system/_dataset_client.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+from collections.abc import Sequence
 from typing import TYPE_CHECKING, Any, Self
 
 from typing_extensions import override
@@ -10,7 +11,7 @@
 from apify.storage_clients._ppe_dataset_mixin import DatasetClientPpeMixin
 
 if TYPE_CHECKING:
-    from collections.abc import Mapping, Sequence
+    from collections.abc import Mapping
 
     from crawlee._types import JsonSerializable
     from crawlee.configuration import Configuration
@@ -53,7 +54,7 @@ async def open(
     @override
     async def push_data(self, data: Sequence[Mapping[str, JsonSerializable]] | Mapping[str, JsonSerializable]) -> None:
         async with charge_lock_if_charging():
-            items = data if self._is_sequence_of_items(data) else [data]
+            items = data if isinstance(data, Sequence) else [data]
             limit = self._compute_limit_for_push(len(items))
 
             await super().push_data(items[:limit])