diff --git a/src/llama_stack/providers/utils/inference/inference_store.py b/src/llama_stack/providers/utils/inference/inference_store.py index 0dc044eac..a3a28aec0 100644 --- a/src/llama_stack/providers/utils/inference/inference_store.py +++ b/src/llama_stack/providers/utils/inference/inference_store.py @@ -66,11 +66,6 @@ class InferenceStore: }, ) - if self.enable_write_queue: - logger.debug( - f"Inference store write queue configured for {self._num_writers} writers, max queue size {self._max_write_queue_size}" - ) - async def shutdown(self) -> None: if not self._worker_tasks: return diff --git a/src/llama_stack/providers/utils/responses/responses_store.py b/src/llama_stack/providers/utils/responses/responses_store.py index 898b16f61..f5024a9ed 100644 --- a/src/llama_stack/providers/utils/responses/responses_store.py +++ b/src/llama_stack/providers/utils/responses/responses_store.py @@ -90,7 +90,6 @@ class ResponsesStore: input: list[OpenAIResponseInput], messages: list[OpenAIMessageParam], ) -> None: - logger.info(f"💾 Writing response id={response_object.id}") await self._write_response_object(response_object, input, messages) async def _write_response_object( @@ -250,8 +249,6 @@ class ResponsesStore: if not self.sql_store: raise ValueError("Responses store is not initialized") - logger.info(f"💬 Storing {len(messages)} messages for conversation {conversation_id}") - # Serialize messages to dict format for JSON storage messages_data = [msg.model_dump() for msg in messages] @@ -261,16 +258,13 @@ class ResponsesStore: table="conversation_messages", data={"conversation_id": conversation_id, "messages": messages_data}, ) - logger.info(f"✅ Inserted conversation messages for {conversation_id}") - except Exception as e: - logger.info(f"🔄 Insert failed, trying update for {conversation_id}: {e}") + except Exception: # If insert fails due to ID conflict, update existing record await self.sql_store.update( table="conversation_messages", data={"messages": messages_data}, where={"conversation_id": conversation_id}, ) - logger.info(f"✅ Updated conversation messages for {conversation_id}") logger.debug(f"Stored {len(messages)} messages for conversation {conversation_id}")