jyapayne/langflow
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

🔧 (model.py): update get_chat_result method to handle input_value as Record type and load prompt if present before processing

Browse source
This commit is contained in:
ogabrielluiz 2024-06-06 14:19:22 -03:00
commit ec4802757a
1 changed files with 14 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/backend/base/langflow/base/models/model.py
View file

@ -1,10 +1,13 @@
import warnings
from typing import Optional, Union from typing import Optional, Union
from langchain_core.language_models.chat_models import BaseChatModel from langchain_core.language_models.chat_models import BaseChatModel
from langchain_core.language_models.llms import LLM from langchain_core.language_models.llms import LLM
from langchain_core.load import load
from langchain_core.messages import AIMessage, HumanMessage, SystemMessage from langchain_core.messages import AIMessage, HumanMessage, SystemMessage
from langflow.custom import CustomComponent from langflow.custom import CustomComponent
from langflow.schema.schema import Record
class LCModelComponent(CustomComponent): class LCModelComponent(CustomComponent):
@ -82,7 +85,7 @@ class LCModelComponent(CustomComponent):
return status_message return status_message
def get_chat_result( def get_chat_result(
self, runnable: BaseChatModel, stream: bool, input_value: str, system_message: Optional[str] = None self, runnable: BaseChatModel, stream: bool, input_value: str | Record, system_message: Optional[str] = None
): ):
messages: list[Union[HumanMessage, SystemMessage]] = [] messages: list[Union[HumanMessage, SystemMessage]] = []
if not input_value and not system_message: if not input_value and not system_message:
@ -90,7 +93,16 @@ class LCModelComponent(CustomComponent):
if system_message: if system_message:
messages.append(SystemMessage(content=system_message)) messages.append(SystemMessage(content=system_message))
if input_value: if input_value:
messages.append(HumanMessage(content=input_value)) if isinstance(input_value, Record):
with warnings.catch_warnings():
warnings.simplefilter("ignore")
if "prompt" in input_value:
prompt = load(input_value.prompt)
runnable = prompt | runnable
else:
messages.append(input_value.to_lc_message())
else:
messages.append(HumanMessage(content=input_value))
if stream: if stream:
return runnable.stream(messages) return runnable.stream(messages)
else: else: