From 7660e14d98dd8ddece43c1a30fd28fa1f9dc5306 Mon Sep 17 00:00:00 2001 From: Vlada Dusek Date: Mon, 20 Apr 2026 14:07:56 +0200 Subject: [PATCH] chore: use cache.get() in shared RQ mark_request_as_handled Align the cache lookup with the analogous code in the single-access client (`_request_queue_single_client.py:204`) so a missing request id no longer raises `KeyError` from the subscript before the surrounding try/except. Co-Authored-By: Claude Opus 4.7 (1M context) --- .../storage_clients/_apify/_request_queue_shared_client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/apify/storage_clients/_apify/_request_queue_shared_client.py b/src/apify/storage_clients/_apify/_request_queue_shared_client.py index eb2b43383..8257ec15d 100644 --- a/src/apify/storage_clients/_apify/_request_queue_shared_client.py +++ b/src/apify/storage_clients/_apify/_request_queue_shared_client.py @@ -216,7 +216,7 @@ async def mark_request_as_handled(self, request: Request) -> ProcessedRequest | if request.handled_at is None: request.handled_at = datetime.now(tz=timezone.utc) - if cached_request := self._requests_cache[request_id]: + if cached_request := self._requests_cache.get(request_id): cached_request.was_already_handled = request.was_already_handled try: # Update the request in the API