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