Skip to content

Commit 3e0d13c

Browse files
committed
fix: Handle None result in single consumer request queue client
1 parent cb2ac3f commit 3e0d13c

1 file changed

Lines changed: 10 additions & 4 deletions

File tree

src/apify/storage_clients/_apify/_request_queue_single_client.py

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -247,10 +247,16 @@ async def _list_head(self) -> None:
247247
else:
248248
# Only fetch the request if we do not know it yet.
249249
if request.unique_key not in self._requests_cache:
250-
request = Request.model_validate(
251-
await self._api_client.get_request(unique_key_to_request_id(request.unique_key))
252-
)
253-
self._requests_cache[request.unique_key] = request
250+
request_id = unique_key_to_request_id(request.unique_key)
251+
complete_request_data = await self._api_client.get_request(request_id)
252+
253+
if complete_request_data is not None:
254+
request = Request.model_validate(complete_request_data)
255+
self._requests_cache[request.unique_key] = request
256+
else:
257+
logger.warning(
258+
f'Could not fetch request data for unique_key=`{request.unique_key}` (id=`{request_id}`)'
259+
)
254260

255261
# Add new requests to the end of the head, unless already present in head
256262
if request.unique_key not in self._head_requests:

0 commit comments

Comments
 (0)