mypy is broken - add type ignore

Author: vdusek

src/crawlee/storages/_dataset.py

@@ -241,7 +241,7 @@ async def push_data(self, data: JsonSerializable, **kwargs: Unpack[PushDataKwarg
         # Handle singular items
         if not isinstance(data, list):
             items = await self.check_and_serialize(data)
-            return await self._resource_client.push_items(items, **kwargs)
+            return await self._resource_client.push_items(items, **kwargs)  # type: ignore[no-any-return] # Mypy is broken
 
         # Handle lists
         payloads_generator = (await self.check_and_serialize(item, index) for index, item in enumerate(data))
@@ -264,7 +264,7 @@ async def get_data(self, **kwargs: Unpack[GetDataKwargs]) -> DatasetItemsListPag
         Returns:
             List page containing filtered and paginated dataset items.
         """
-        return await self._resource_client.list_items(**kwargs)
+        return await self._resource_client.list_items(**kwargs)  # type: ignore[no-any-return] # Mypy is broken
 
     async def write_to_csv(self, destination: TextIO, **kwargs: Unpack[ExportDataCsvKwargs]) -> None:
         """Exports the entire dataset into an arbitrary stream.

src/crawlee/storages/_key_value_store.py

@@ -72,7 +72,7 @@ def name(self) -> str | None:
 
     async def get_info(self) -> KeyValueStoreMetadata | None:
         """Get an object containing general information about the key value store."""
-        return await self._resource_client.get()
+        return await self._resource_client.get()  # type: ignore[no-any-return] # Mypy is broken
 
     @override
     @classmethod
@@ -142,9 +142,9 @@ async def set_value(
             content_type: Content type of the record.
         """
         if value is None:
-            return await self._resource_client.delete_record(key)
+            return await self._resource_client.delete_record(key)  # type: ignore[no-any-return] # Mypy is broken
 
-        return await self._resource_client.set_record(key, value, content_type)
+        return await self._resource_client.set_record(key, value, content_type)  # type: ignore[no-any-return] # Mypy is broken
 
     async def get_public_url(self, key: str) -> str:
         """Get the public URL for the given key.
@@ -155,4 +155,4 @@ async def get_public_url(self, key: str) -> str:
         Returns:
             The public URL for the given key.
         """
-        return await self._resource_client.get_public_url(key)
+        return await self._resource_client.get_public_url(key)  # type: ignore[no-any-return] # Mypy is broken

src/crawlee/storages/_request_queue.py

@@ -204,7 +204,7 @@ async def add_request(
         ):
             self._assumed_total_count += 1
 
-        return processed_request
+        return processed_request  # type: ignore[no-any-return] # Mypy is broken
 
     @override
     async def add_requests_batched(
@@ -260,7 +260,7 @@ async def get_request(self, request_id: str) -> Request | None:
         Returns:
             The retrieved request, or `None`, if it does not exist.
         """
-        return await self._resource_client.get_request(request_id)
+        return await self._resource_client.get_request(request_id)  # type: ignore[no-any-return] # Mypy is broken
 
     async def fetch_next_request(self) -> Request | None:
         """Return the next request in the queue to be processed.
@@ -373,7 +373,7 @@ async def mark_request_as_handled(self, request: Request) -> ProcessedRequest |
             self._assumed_handled_count += 1
 
         self._cache_request(unique_key_to_request_id(request.unique_key), processed_request)
-        return processed_request
+        return processed_request  # type: ignore[no-any-return] # Mypy is broken
 
     async def reclaim_request(
         self,
@@ -417,7 +417,7 @@ async def reclaim_request(
             except Exception as err:
                 logger.debug(f'Failed to delete request lock for request {request.id}', exc_info=err)
 
-        return processed_request
+        return processed_request  # type: ignore[no-any-return] # Mypy is broken
 
     async def is_empty(self) -> bool:
         """Check whether the queue is empty.
@@ -483,7 +483,7 @@ async def is_finished(self) -> bool:
 
     async def get_info(self) -> RequestQueueMetadata | None:
         """Get an object containing general information about the request queue."""
-        return await self._resource_client.get()
+        return await self._resource_client.get()  # type: ignore[no-any-return] # Mypy is broken
 
     @override
     async def get_handled_count(self) -> int:
@@ -658,7 +658,7 @@ async def _prolong_request_lock(self, request_id: str) -> datetime | None:
             )
             return None
         else:
-            return res.lock_expires_at
+            return res.lock_expires_at  # type: ignore[no-any-return] # Mypy is broken
 
     async def _clear_possible_locks(self) -> None:
         self._queue_paused_for_migration = True