diff --git a/server/reflector/llm/base.py b/server/reflector/llm/base.py index 0f2c91c7..e528a3e6 100644 --- a/server/reflector/llm/base.py +++ b/server/reflector/llm/base.py @@ -39,8 +39,7 @@ class LLM: duration = monotonic() - start logger.info(f"LLM[{name}] warmup took {duration:.2f} seconds") except Exception: - logger.exception(f"LLM[{name}] warmup failed") - raise + logger.exception(f"LLM[{name}] warmup failed, ignoring") async def _warmup(self, logger: reflector_logger): pass diff --git a/server/reflector/processors/base.py b/server/reflector/processors/base.py index 85cbc3fd..4a7f2bc2 100644 --- a/server/reflector/processors/base.py +++ b/server/reflector/processors/base.py @@ -143,7 +143,12 @@ class ThreadedProcessor(Processor): self.logger.debug(f"Warming up {self.processor.__class__.__name__}") await self.processor.warmup() continue - await self.processor.push(data) + try: + await self.processor.push(data) + except Exception: + self.logger.error( + f"Error in push {self.processor.__class__.__name__}, continue" + ) finally: self.queue.task_done()