requeue failed requests

olegeech-me · Oct 15, 2023 · dccd104 · dccd104
1 parent 8f1d175
commit dccd104
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/fetcher/application_processor.py b/src/fetcher/application_processor.py
@@ -132,7 +132,8 @@ async def _process_request(self, message, request_type):
 
         except Exception as e:
             logger.error("%s Error processing request: %s", log_prefix, e)
-            self.metrics_collector.record_fetch_status("failed")
+            queue_name = "ApplicationFetchQueue" if request_type == "fetch" else "RefreshStatusQueue"
+            await self._manage_failed_request(message, queue_name)
         finally:
             await self.end_processing(request_type, number, type_, year)