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

[Anthropic] Shallow Copy (#27105)

Browse Source 
Co-authored-by: Erick Friis <erick@langchain.dev>
This commit is contained in:
William FH 2024-10-15 08:50:48 -07:00 committed by GitHub
parent c6533616b6
commit 0a3e089827
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
libs/partners/anthropic/langchain_anthropic/chat_models.py
View File

@ -1,3 +1,4 @@
import copy
import re import re
import warnings import warnings
from operator import itemgetter from operator import itemgetter
@ -116,7 +117,6 @@ def _merge_messages(
"""Merge runs of human/tool messages into single human messages with content blocks.""" # noqa: E501 """Merge runs of human/tool messages into single human messages with content blocks.""" # noqa: E501
merged: list = [] merged: list = []
for curr in messages: for curr in messages:
curr = curr.model_copy(deep=True)
if isinstance(curr, ToolMessage): if isinstance(curr, ToolMessage):
if ( if (
isinstance(curr.content, list) isinstance(curr.content, list)
@ -143,12 +143,12 @@ def _merge_messages(
if isinstance(last.content, str): if isinstance(last.content, str):
new_content: List = [{"type": "text", "text": last.content}] new_content: List = [{"type": "text", "text": last.content}]
else: else:
new_content = last.content new_content = copy.copy(last.content)
if isinstance(curr.content, str): if isinstance(curr.content, str):
new_content.append({"type": "text", "text": curr.content}) new_content.append({"type": "text", "text": curr.content})
else: else:
new_content.extend(curr.content) new_content.extend(curr.content)
last.content = new_content merged[-1] = curr.model_copy(update={"content": new_content}, deep=False)
else: else:
merged.append(curr) merged.append(curr)
return merged return merged
@ -178,9 +178,11 @@ def _format_messages(
raise ValueError("System message must be at beginning of message list.") raise ValueError("System message must be at beginning of message list.")
if isinstance(message.content, list): if isinstance(message.content, list):
system = [ system = [
(
block block
if isinstance(block, dict) if isinstance(block, dict)
else {"type": "text", "text": "block"} else {"type": "text", "text": "block"}
)
for block in message.content for block in message.content
] ]
else: else: