move the empty text skips to the agent

src/backend/base/langflow/base/agents/agent.py

@@ -118,6 +118,24 @@ def get_chat_history_data(self) -> list[Data] | None:
         # might be overridden in subclasses
         return None
 
+    def _data_to_messages_skip_empty(self, data: list[Data]):
+        """Convert data to messages, filtering only empty text while preserving non-text content.
+
+        Note: added to fix issue with certain providers failing when given empty text.
+        """
+        messages = []
+        for value in data:
+            # Only skip if the message has a text attribute that is empty/whitespace
+            text = getattr(value, "text", None)
+            if isinstance(text, str) and not text.strip():
+                # Skip only messages with empty/whitespace-only text strings
+                continue
+
+            lc_message = value.to_lc_message()
+            messages.append(lc_message)
+
+        return messages
+
     async def run_agent(
         self,
         agent: Runnable | BaseSingleActionAgent | BaseMultiActionAgent | AgentExecutor,
@@ -153,12 +171,14 @@ async def run_agent(
 
         if hasattr(self, "chat_history") and self.chat_history:
             if isinstance(self.chat_history, Data):
-                input_dict["chat_history"] = data_to_messages(self.chat_history)
+                input_dict["chat_history"] = self._data_to_messages_skip_empty(self.chat_history)
+
             # Handle both lfx.schema.message.Message and langflow.schema.message.Message types
             if all(hasattr(m, "to_data") and callable(m.to_data) and "text" in m.data for m in self.chat_history):
-                input_dict["chat_history"] = data_to_messages(self.chat_history)
+                input_dict["chat_history"] = self._data_to_messages_skip_empty(self.chat_history)
+
             if all(isinstance(m, Message) for m in self.chat_history):
-                input_dict["chat_history"] = data_to_messages([m.to_data() for m in self.chat_history])
+                input_dict["chat_history"] = self._data_to_messages_skip_empty([m.to_data() for m in self.chat_history])
 
         if (
             hasattr(lc_message, "content")
@@ -169,7 +189,6 @@ async def run_agent(
 
         if lc_message and hasattr(lc_message, "content") and isinstance(lc_message.content, list):
             # ! Because the input has to be a string, we must pass the images in the chat_history
-
             image_dicts = [item for item in lc_message.content if item.get("type") == "image"]
             lc_message.content = [item for item in lc_message.content if item.get("type") != "image"]
             text_content = [item for item in input_dict["input"].content if item.get("type") != "image"]

src/backend/base/langflow/base/agents/utils.py

@@ -48,12 +48,7 @@ def data_to_messages(data: list[Data]) -> list[BaseMessage]:
     Returns:
         List[Message]: The data as messages.
     """
-    messages = []
-    for value in data:
-        # Skip messages with empty or None text to avoid errors with some model providers
-        if hasattr(value, "text") and value.text and str(value.text).strip():
-            messages.append(value.to_lc_message())
-    return messages
+    return [value.to_lc_message() for value in data]
 
 
 def validate_and_create_xml_agent(

src/backend/tests/unit/components/agents/test_agent_events.py

@@ -544,25 +544,18 @@ async def test_handle_on_chain_stream_no_output():
     assert isinstance(start_time, float)
 
 async def test_agent_streaming_no_text_accumulation():
-    """Test that agent streaming sends individual token events without accumulating text."""
+    """Test that agent streaming sends individual chunks without accumulating text."""
     sent_messages = []
-    token_events = []
 
     async def mock_send_message(message):
         # Capture each message sent for verification
-        sent_messages.append(
-            {"text": message.text, "state": message.properties.state, "id": getattr(message, "id", None)}
-        )
+        sent_messages.append({
+            'text': message.text,
+            'state': message.properties.state,
+            'id': getattr(message, 'id', None)
+        })
         return message
 
-    # Mock event manager to capture token events
-    class MockEventManager:
-        def on_token(self, data):
-            # Capture token events
-            token_events.append(data)
-
-    event_manager = MockEventManager()
-
     agent_message = Message(
         sender=MESSAGE_SENDER_AI,
         sender_name="Agent",
@@ -616,7 +609,6 @@ def on_token(self, data):
     assert result.properties.state == "complete"
     assert result.text == "Hello world!"
 
-
 async def test_agent_streaming_without_event_manager():
     """Test that agent streaming works without event_manager (backward compatibility)."""
     sent_messages = []