Skip to content

Commit 1045195

Browse files
vdusekclaude
andcommitted
fix: log RQ mark_request_as_handled and reclaim_request errors at exception level
Errors in `mark_request_as_handled` and `reclaim_request` in both the single and shared request queue clients were logged at DEBUG level, making API failures (network timeouts, auth errors, rate limits) effectively invisible. Upgrade to `logger.exception` so these errors are visible and include full tracebacks. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 7ad2450 commit 1045195

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/apify/storage_clients/_apify/_request_queue_shared_client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,7 @@ async def mark_request_as_handled(self, request: Request) -> ProcessedRequest |
236236
hydrated_request=request,
237237
)
238238
except Exception as exc:
239-
logger.debug(f'Error marking request {request.unique_key} as handled: {exc!s}')
239+
logger.exception(f'Error marking request {request.unique_key} as handled: {exc!s}')
240240
return None
241241
else:
242242
return processed_request
@@ -280,7 +280,7 @@ async def reclaim_request(
280280
self._should_check_for_forefront_requests = True
281281

282282
except Exception as exc:
283-
logger.debug(f'Error reclaiming request {request.unique_key}: {exc!s}')
283+
logger.exception(f'Error reclaiming request {request.unique_key}: {exc!s}')
284284
return None
285285
else:
286286
return processed_request

src/apify/storage_clients/_apify/_request_queue_single_client.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,7 +221,7 @@ async def mark_request_as_handled(self, request: Request) -> ProcessedRequest |
221221
self._requests_in_progress.discard(request_id)
222222

223223
except Exception as exc:
224-
logger.debug(f'Error marking request {request.unique_key} as handled: {exc!s}')
224+
logger.exception(f'Error marking request {request.unique_key} as handled: {exc!s}')
225225
return None
226226
else:
227227
return processed_request
@@ -264,7 +264,7 @@ async def reclaim_request(
264264
self.metadata.pending_request_count += 1
265265

266266
except Exception as exc:
267-
logger.debug(f'Error reclaiming request {request.unique_key}: {exc!s}')
267+
logger.exception(f'Error reclaiming request {request.unique_key}: {exc!s}')
268268
return None
269269
else:
270270
return processed_request

0 commit comments

Comments
 (0)