From 3e0d13cdb9a605a33fdd58de7310ad4e8634be6a Mon Sep 17 00:00:00 2001 From: Jan Buchar Date: Thu, 9 Oct 2025 10:41:42 +0200 Subject: [PATCH] fix: Handle None result in single consumer request queue client --- .../_apify/_request_queue_single_client.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/src/apify/storage_clients/_apify/_request_queue_single_client.py b/src/apify/storage_clients/_apify/_request_queue_single_client.py index 1b9502b0..80b8ced7 100644 --- a/src/apify/storage_clients/_apify/_request_queue_single_client.py +++ b/src/apify/storage_clients/_apify/_request_queue_single_client.py @@ -247,10 +247,16 @@ async def _list_head(self) -> None: else: # Only fetch the request if we do not know it yet. if request.unique_key not in self._requests_cache: - request = Request.model_validate( - await self._api_client.get_request(unique_key_to_request_id(request.unique_key)) - ) - self._requests_cache[request.unique_key] = request + request_id = unique_key_to_request_id(request.unique_key) + complete_request_data = await self._api_client.get_request(request_id) + + if complete_request_data is not None: + request = Request.model_validate(complete_request_data) + self._requests_cache[request.unique_key] = request + else: + logger.warning( + f'Could not fetch request data for unique_key=`{request.unique_key}` (id=`{request_id}`)' + ) # Add new requests to the end of the head, unless already present in head if request.unique_key not in self._head_requests: