Format and type check

Author: Pijukatel

src/apify/storage_clients/_apify/_request_queue_client.py

@@ -240,7 +240,7 @@ async def add_batch_of_requests(
         """
         # Do not try to add previously added requests to avoid pointless expensive calls to API
         new_requests: list[Request] = []
-        already_present_requests: list[ProcessedRequest] = []
+        already_present_requests: list[dict[str, str | bool]] = []
         for request in requests:
             if self._requests_cache.get(request.id):
                 # We are no sure if it was already handled at this point, and it is not worth calling API for it.

tests/integration/test_actor_request_queue.py

@@ -129,18 +129,25 @@ async def main() -> None:
 
         async with Actor:
             request = Request.from_url('http://example.com')
-            rq = await Actor.open_request_queue(name='test-deduplication', force_cloud=True)
+            rq = await Actor.open_request_queue()
 
             await asyncio.sleep(10)  # Wait to be sure that metadata are updated
-            stats_before = (await Actor.apify_client.request_queue(request_queue_id=rq.id).get()).get('stats', {})
+
+            # Get raw client, because stats are not exposed in `RequestQueue` class, but are available in raw client
+            rq_client = Actor.apify_client.request_queue(request_queue_id=rq.id)
+            _rq = await rq_client.get()
+            assert _rq
+            stats_before = _rq.get('stats', {})
             Actor.log.info(stats_before)
 
             # Add same request twice
             await rq.add_request(request)
             await rq.add_request(request)
 
             await asyncio.sleep(10)  # Wait to be sure that metadata are updated
-            stats_after = (await Actor.apify_client.request_queue(request_queue_id=rq.id).get()).get('stats', {})
+            _rq = await rq_client.get()
+            assert _rq
+            stats_after = _rq.get('stats', {})
             Actor.log.info(stats_after)
 
             assert (stats_after['writeCount'] - stats_before['writeCount']) == 1