diff --git a/tests/integration/test_request_queue.py b/tests/integration/test_request_queue.py index ab8967d2..d9fb8000 100644 --- a/tests/integration/test_request_queue.py +++ b/tests/integration/test_request_queue.py @@ -723,14 +723,8 @@ async def test_persistence_across_operations( assert final_handled == 15, f'final_handled={final_handled}' -async def test_request_deduplication_edge_cases( - request_queue_apify: RequestQueue, request: pytest.FixtureRequest -) -> None: +async def test_request_deduplication_edge_cases(request_queue_apify: RequestQueue) -> None: """Test edge cases in request deduplication.""" - rq_access_mode = request.node.callspec.params.get('request_queue_apify') - if rq_access_mode == 'shared': - pytest.skip(reason='Test is flaky, see https://github.com/apify/apify-sdk-python/issues/786') - rq = request_queue_apify Actor.log.info('Request queue opened') @@ -749,7 +743,12 @@ async def test_request_deduplication_edge_cases( results = list[bool]() for url, expected_duplicate in urls_and_deduplication_expectations: - result = await rq.add_request(url) + # add_request may transiently return None due to platform-side issues, retry up to 3 times. + for _ in range(3): + result = await rq.add_request(url) + if result is not None: + break # Successfully added. + assert result is not None results.append(result.was_already_present) assert result.was_already_present == expected_duplicate, ( diff --git a/uv.lock b/uv.lock index f98fe747..99b488ad 100644 --- a/uv.lock +++ b/uv.lock @@ -3,9 +3,15 @@ revision = 3 requires-python = ">=3.10" [options] -exclude-newer = "2026-04-26T08:17:16.734666375Z" +exclude-newer = "0001-01-01T00:00:00Z" # This has no effect and is included for backwards compatibility when using relative exclude-newer values. exclude-newer-span = "PT24H" +[options.exclude-newer-package] +apify-fingerprint-datapoints = false +crawlee = false +apify-shared = false +apify-client = false + [[package]] name = "annotated-types" version = "0.7.0"