diff --git a/src/backend/langflow/api/v1/base.py b/src/backend/langflow/api/v1/base.py index 28be40ae0..420e1645f 100644 --- a/src/backend/langflow/api/v1/base.py +++ b/src/backend/langflow/api/v1/base.py @@ -14,7 +14,7 @@ class Code(BaseModel): class FrontendNodeRequest(FrontendNode): - template: dict + template: dict # type: ignore class ValidatePromptRequest(BaseModel): diff --git a/src/backend/langflow/chat/utils.py b/src/backend/langflow/chat/utils.py index d070a7457..7db65b8e3 100644 --- a/src/backend/langflow/chat/utils.py +++ b/src/backend/langflow/chat/utils.py @@ -21,6 +21,10 @@ async def process_graph( # Generate result and thought try: + if not chat_inputs.message: + logger.debug("No message provided") + raise ValueError("No message provided") + logger.debug("Generating result and thought") result, intermediate_steps = await get_result_and_steps( langchain_object, chat_inputs.message, websocket=websocket diff --git a/src/backend/langflow/interface/initialize/loading.py b/src/backend/langflow/interface/initialize/loading.py index d56445f2a..37dbdcda1 100644 --- a/src/backend/langflow/interface/initialize/loading.py +++ b/src/backend/langflow/interface/initialize/loading.py @@ -193,7 +193,7 @@ def instantiate_prompt(node_type, class_object, params: Dict): prompt = class_object(**params) - format_kwargs = {} + format_kwargs: Dict[str, Any] = {} for input_variable in prompt.input_variables: if input_variable in params: variable = params[input_variable] diff --git a/src/backend/langflow/processing/base.py b/src/backend/langflow/processing/base.py index b39ad4af1..478b98816 100644 --- a/src/backend/langflow/processing/base.py +++ b/src/backend/langflow/processing/base.py @@ -1,3 +1,4 @@ +from typing import Union from langflow.api.v1.callback import ( AsyncStreamingLLMCallbackHandler, StreamingLLMCallbackHandler, @@ -6,7 +7,7 @@ from langflow.processing.process import fix_memory_inputs, format_actions from langflow.utils.logger import logger -async def get_result_and_steps(langchain_object, inputs: dict, **kwargs): +async def get_result_and_steps(langchain_object, inputs: Union[dict, str], **kwargs): """Get result and thought from extracted json""" try: