test: Fix flaky test_request_reclaim_functionality[shared] integration test

Add retry logic to fetch_next_request() calls in the reclaim test to handle
propagation delays in shared request queue access mode. The shared mode may
have a brief delay before newly added or reclaimed requests become visible.

See: https://github.com/apify/apify-sdk-python/actions/runs/22150409354/job/64039850655?pr=793

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: vdusek

tests/integration/test_request_queue.py

@@ -208,6 +208,16 @@ async def test_request_unique_key_behavior(request_queue_apify: RequestQueue) ->
     )
 
 
+async def _fetch_next_request_with_retry(rq: RequestQueue, *, max_retries: int = 10, delay: float = 1.0) -> Any:
+    """Fetch the next request with retries to handle propagation delays in shared mode."""
+    for _ in range(max_retries):
+        request = await rq.fetch_next_request()
+        if request is not None:
+            return request
+        await asyncio.sleep(delay)
+    return None
+
+
 async def test_request_reclaim_functionality(request_queue_apify: RequestQueue) -> None:
     """Test request reclaiming for failed processing."""
 
@@ -218,8 +228,8 @@ async def test_request_reclaim_functionality(request_queue_apify: RequestQueue)
     await rq.add_request('https://example.com/test')
     Actor.log.info('Added test request')
 
-    # Fetch and reclaim the request
-    request = await rq.fetch_next_request()
+    # Fetch and reclaim the request (retry to handle propagation delay in shared mode)
+    request = await _fetch_next_request_with_retry(rq)
     assert request is not None, f'request={request}'
     Actor.log.info(f'Fetched request: {request.url}')
 
@@ -231,8 +241,8 @@ async def test_request_reclaim_functionality(request_queue_apify: RequestQueue)
     )
     Actor.log.info('Request reclaimed successfully')
 
-    # Should be able to fetch the same request again
-    request2 = await rq.fetch_next_request()
+    # Should be able to fetch the same request again (retry to handle propagation delay in shared mode)
+    request2 = await _fetch_next_request_with_retry(rq)
     assert request2 is not None, f'request2={request2}'
     assert request2.url == request.url, (
         f'request2.url={request2.url}',