phoenix-oss/llama-stack-mirror
0
0
Fork 1
mirror of https://github.com/meta-llama/llama-stack.git synced 2025-12-03 09:53:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

killed unnecessary logs

Browse source
This commit is contained in:
Ashwin Bharambe 2025-11-12 10:20:48 -08:00
parent 08024d44f2
commit 531e00366f
2 changed files with 1 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/llama_stack/providers/utils/inference/inference_store.py
View file

@ -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: async def shutdown(self) -> None:
if not self._worker_tasks: if not self._worker_tasks:
return return

8
src/llama_stack/providers/utils/responses/responses_store.py
View file

@ -90,7 +90,6 @@ class ResponsesStore:
input: list[OpenAIResponseInput], input: list[OpenAIResponseInput],
messages: list[OpenAIMessageParam], messages: list[OpenAIMessageParam],
) -> None: ) -> None:
logger.info(f"💾 Writing response id={response_object.id}")
await self._write_response_object(response_object, input, messages) await self._write_response_object(response_object, input, messages)
async def _write_response_object( async def _write_response_object(
@ -250,8 +249,6 @@ class ResponsesStore:
if not self.sql_store: if not self.sql_store:
raise ValueError("Responses store is not initialized") 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 # Serialize messages to dict format for JSON storage
messages_data = [msg.model_dump() for msg in messages] messages_data = [msg.model_dump() for msg in messages]
@ -261,16 +258,13 @@ class ResponsesStore:
table="conversation_messages", table="conversation_messages",
data={"conversation_id": conversation_id, "messages": messages_data}, data={"conversation_id": conversation_id, "messages": messages_data},
) )
logger.info(f"✅ Inserted conversation messages for {conversation_id}") except Exception:
except Exception as e:
logger.info(f"🔄 Insert failed, trying update for {conversation_id}: {e}")
# If insert fails due to ID conflict, update existing record # If insert fails due to ID conflict, update existing record
await self.sql_store.update( await self.sql_store.update(
table="conversation_messages", table="conversation_messages",
data={"messages": messages_data}, data={"messages": messages_data},
where={"conversation_id": conversation_id}, 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}") logger.debug(f"Stored {len(messages)} messages for conversation {conversation_id}")