github/langchain
1
0
Fork 0
mirror of https://github.com/hwchase17/langchain.git synced 2025-08-11 13:55:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove run id from hot path

Browse Source
This commit is contained in:
Sydney Runkle 2025-05-13 19:43:40 -07:00
parent 16ea462b7d
commit d3d2fddb53
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libs/core/langchain_core/language_models/chat_models.py
View File

@ -494,9 +494,10 @@ class BaseChatModel(BaseLanguageModel[BaseMessage], ABC):
try: try:
input_messages = _normalize_messages(messages) input_messages = _normalize_messages(messages)
run_id = "-".join((_LC_ID_PREFIX, str(run_manager.run_id)))
for chunk in self._stream(input_messages, stop=stop, **kwargs): for chunk in self._stream(input_messages, stop=stop, **kwargs):
if chunk.message.id is None: if chunk.message.id is None:
chunk.message.id = f"{_LC_ID_PREFIX}-{run_manager.run_id}" chunk.message.id = run_id
chunk.message.response_metadata = _gen_info_and_msg_metadata(chunk) chunk.message.response_metadata = _gen_info_and_msg_metadata(chunk)
run_manager.on_llm_new_token( run_manager.on_llm_new_token(
cast("str", chunk.message.content), chunk=chunk cast("str", chunk.message.content), chunk=chunk
@ -586,13 +587,14 @@ class BaseChatModel(BaseLanguageModel[BaseMessage], ABC):
try: try:
input_messages = _normalize_messages(messages) input_messages = _normalize_messages(messages)
run_id = "-".join((_LC_ID_PREFIX, str(run_manager.run_id)))
async for chunk in self._astream( async for chunk in self._astream(
input_messages, input_messages,
stop=stop, stop=stop,
**kwargs, **kwargs,
): ):
if chunk.message.id is None: if chunk.message.id is None:
chunk.message.id = f"{_LC_ID_PREFIX}-{run_manager.run_id}" chunk.message.id = run_id
chunk.message.response_metadata = _gen_info_and_msg_metadata(chunk) chunk.message.response_metadata = _gen_info_and_msg_metadata(chunk)
await run_manager.on_llm_new_token( await run_manager.on_llm_new_token(
cast("str", chunk.message.content), chunk=chunk cast("str", chunk.message.content), chunk=chunk