Catch langchain agent errors

morpheus/llm/nodes/langchain_agent_node.py

@@ -66,9 +66,14 @@ async def _run_single(self, **kwargs: dict[str, typing.Any]) -> dict[str, typing
  return results
 
  # We are not dealing with a list, so run single
- return await self._agent_executor.arun(**kwargs)
-
- async def execute(self, context: LLMContext) -> LLMContext:
+ try:
+ return await self._agent_executor.arun(**kwargs)
+ except Exception as e:
+ error_msg = f"Error running agent: {e}"
+ logger.exception(error_msg)
+ return error_msg
+
+ async def execute(self, context: LLMContext) -> LLMContext: # pylint: disable=invalid-overridden-method
 
  input_dict = context.get_inputs()