Fix some blocking usages of messages memory

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

@@ -1,4 +1,5 @@
 # Add helper functions for each event type
+import asyncio
 from collections.abc import AsyncIterator
 from time import perf_counter
 from typing import Any, Protocol
@@ -235,7 +236,7 @@ async def process_agent_events(
         agent_message.properties.icon = "Bot"
         agent_message.properties.state = "partial"
     # Store the initial message
-    agent_message = send_message_method(message=agent_message)
+    agent_message = asyncio.to_thread(send_message_method, message=agent_message)
     try:
         # Create a mapping of run_ids to tool contents
         tool_blocks_map: dict[str, ToolContent] = {}

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

@@ -1,3 +1,5 @@
+import asyncio
+
 from langchain_core.tools import StructuredTool
 
 from langflow.base.agents.agent import LCToolsAgentComponent
@@ -58,7 +60,7 @@ async def message_response(self) -> Message:
         if llm_model is None:
             msg = "No language model selected"
             raise ValueError(msg)
-        self.chat_history = self.get_memory_data()
+        self.chat_history = await asyncio.to_thread(self.get_memory_data)
 
         if self.add_current_date_tool:
             if not isinstance(self.tools, list):  # type: ignore[has-type]

src/backend/base/langflow/custom/custom_component/component.py

@@ -797,15 +797,17 @@ async def build_results(self):
                 return await self._build_with_tracing()
             return await self._build_without_tracing()
         except StreamingError as e:
-            self.send_error(
+            await asyncio.to_thread(
+                self.send_error,
                 exception=e.cause,
                 session_id=self.graph.session_id,
                 trace_name=getattr(self, "trace_name", None),
                 source=e.source,
             )
             raise e.cause  # noqa: B904
         except Exception as e:
-            self.send_error(
+            await asyncio.to_thread(
+                self.send_error,
                 exception=e,
                 session_id=self.graph.session_id,
                 source=Source(id=self._id, display_name=self.display_name, source=self.display_name),

src/backend/base/langflow/graph/vertex/types.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 
+import asyncio
 import contextlib
 import json
 from collections.abc import AsyncIterator, Generator, Iterator
@@ -434,7 +435,7 @@ async def stream(self):
             and hasattr(self.custom_component, "should_store_message")
             and hasattr(self.custom_component, "store_message")
         ):
-            self.custom_component.store_message(message)
+            await asyncio.to_thread(self.custom_component.store_message, message)
         log_vertex_build(
             flow_id=self.graph.flow_id,
             vertex_id=self.id,