@@ -199,6 +199,9 @@ async def test_request_unique_key_behavior(request_queue_apify: RequestQueue) ->
199199 result1 = await rq.add_request(req1)
200200 result2 = await rq.add_request(req2)
201201 result3 = await rq.add_request(req3)
202+ assert result1 is not None
203+ assert result2 is not None
204+ assert result3 is not None
202205
203206 Actor.log.info(
204207 f'Added requests - was_already_present: [{result1.was_already_present}, '
@@ -378,6 +381,7 @@ async def test_get_request_by_unique_key(request_queue_apify: RequestQueue) -> N
378381
379382 # Add a request and get its unique_key
380383 add_result = await rq.add_request('https://example.com/test')
384+ assert add_result is not None
381385 request_unique_key = add_result.unique_key
382386 Actor.log.info(f'Request added with unique_key: {request_unique_key}')
383387
@@ -752,6 +756,7 @@ async def test_request_deduplication_edge_cases(
752756 results = list[bool]()
753757 for url, expected_duplicate in urls_and_deduplication_expectations:
754758 result = await rq.add_request(url)
759+ assert result is not None
755760 results.append(result.was_already_present)
756761 assert result.was_already_present == expected_duplicate, (
757762 f'url={url}',
@@ -1038,6 +1043,7 @@ async def test_rq_long_url(
10381043 request_id = unique_key_to_request_id(long_url_request.unique_key)
10391044
10401045 processed_request = await rq.add_request(long_url_request)
1046+ assert processed_request is not None
10411047 assert processed_request.id == request_id
10421048
10431049 request_obtained = await rq.fetch_next_request()
@@ -1083,6 +1089,7 @@ async def test_force_cloud(
10831089) -> None:
10841090 request_queue_id = (await request_queue_apify.get_metadata()).id
10851091 request_info = await request_queue_apify.add_request(Request.from_url('http://example.com'))
1092+ assert request_info is not None
10861093 assert request_info.id is not None
10871094 request_queue_client = apify_client_async.request_queue(request_queue_id)
10881095
0 commit comments