We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9a5c812 commit f2637d5Copy full SHA for f2637d5
src/apify/storage_clients/_apify/_request_queue_client.py
@@ -323,6 +323,15 @@ async def fetch_next_request(self) -> Request | None:
323
)
324
return None
325
326
+ # Use get request to ensure we have the full request object.
327
+ request = await self.get_request(request.id)
328
+ if request is None:
329
+ logger.debug(
330
+ 'Request fetched from the beginning of queue was not found in the RQ',
331
+ extra={'nextRequestId': next_request_id},
332
+ )
333
+ return None
334
+
335
return request
336
337
@override
0 commit comments