diff --git a/src/backend/base/langflow/schema/schema.py b/src/backend/base/langflow/schema/schema.py index fb7ada8e02f3..6008ef625a6d 100644 --- a/src/backend/base/langflow/schema/schema.py +++ b/src/backend/base/langflow/schema/schema.py @@ -2,6 +2,7 @@ from enum import Enum from typing import Literal +from pandas import Series from pydantic import BaseModel from typing_extensions import TypedDict @@ -78,6 +79,9 @@ def get_message(payload): if message is None and isinstance(payload, dict | str | Data): message = payload.data if isinstance(payload, Data) else payload + if isinstance(message, Series): + return message if not message.empty else payload + return message or payload