Fail to run camel agent with MCP as tools due to coroutine result cannot be pickled

[fMeow]

I am testing camel-ai with MCP supports, and I found it completely unusable because some async issue.

When I run agent.step(), it call MCP tools which are async tools, and it tried dumping the following MemoryRecord with pickle.

MemoryRecord(message=FunctionCallingMessage(role_name='Assistant', role_type=<RoleType.ASSISTANT: 'assistant'>, meta_dict=None, content='', video_bytes=None, image_list=None, image_detail='auto', video_detail='low', parsed=None, func_name='list_allowed_directories', args=None, result=<coroutine object MCPClient.generate_function_from_mcp_tool.<locals>.dynamic_function at 0x10aa443d0>, tool_call_id='call_6zvdq3v4'), role_at_backend=<OpenAIBackendRole.FUNCTION: 'function'>, uuid=UUID('4e789211-e8ad-4e43-88ff-3543b786da9f'), extra_info={}, timestamp=1744813388.8594499, agent_id='dbf2f7c1-fbcc-489a-92b1-f29286286cca')

The result field of above MemoryRecord is a coroutine object, which cause python abort abnormally. Here is the complete tracebac:

Traceback (most recent call last):
  File "test.py", line 58, in <module>
    loop.run_until_complete(main())
  File "/opt/homebrew/Cellar/[email protected]/3.12.10/Frameworks/Python.framework/Versions/3.12/lib/python3.12/asyncio/base_events.py", line 691, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "test.py", line 52, in main
    assistant_response = agent.step(user_msg)
                         ^^^^^^^^^^^^^^^^^^^^
  File "venv/lib/python3.12/site-packages/camel/agents/chat_agent.py", line 628, in step
    self._execute_tool(tool_call_request)
  File "venv/lib/python3.12/site-packages/camel/agents/chat_agent.py", line 1295, in _execute_tool
    return self._record_tool_calling(func_name, args, result, tool_call_id)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "venv/lib/python3.12/site-packages/camel/agents/chat_agent.py", line 1351, in _record_tool_calling
    self.update_memory(
  File "venv/lib/python3.12/site-packages/camel/agents/chat_agent.py", line 347, in update_memory
    self.memory.write_record(
  File "venv/lib/python3.12/site-packages/camel/memories/base.py", line 46, in write_record
    self.write_records([record])
  File "venv/lib/python3.12/site-packages/camel/memories/agent_memories.py", line 83, in write_records
    self._chat_history_block.write_records(records)
  File "venv/lib/python3.12/site-packages/camel/memories/blocks/chat_history_block.py", line 162, in write_records
    stored_records.append(record.to_dict())
                          ^^^^^^^^^^^^^^^^
  File "venv/lib/python3.12/site-packages/camel/memories/records.py", line 90, in to_dict
    **asdict(self.message),
      ^^^^^^^^^^^^^^^^^^^^
  File "/opt/homebrew/Cellar/[email protected]/3.12.10/Frameworks/Python.framework/Versions/3.12/lib/python3.12/dataclasses.py", line 1329, in asdict
    return _asdict_inner(obj, dict_factory)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/homebrew/Cellar/[email protected]/3.12.10/Frameworks/Python.framework/Versions/3.12/lib/python3.12/dataclasses.py", line 1339, in _asdict_inner
    f.name: _asdict_inner(getattr(obj, f.name), dict)
            ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/opt/homebrew/Cellar/[email protected]/3.12.10/Frameworks/Python.framework/Versions/3.12/lib/python3.12/dataclasses.py", line 1386, in _asdict_inner
    return copy.deepcopy(obj)
           ^^^^^^^^^^^^^^^^^^
  File "/opt/homebrew/Cellar/[email protected]/3.12.10/Frameworks/Python.framework/Versions/3.12/lib/python3.12/copy.py", line 151, in deepcopy
    rv = reductor(4)
         ^^^^^^^^^^^
TypeError: cannot pickle 'coroutine' object

minimal viable code

from typing import List
from camel.models import ModelFactory
from camel.types import ModelPlatformType, ModelType
from camel.types.enums import ModelType
from camel.agents import ChatAgent
import asyncio
from mcp.types import CallToolResult
from camel.toolkits.mcp_toolkit import MCPToolkit, MCPClient

async def main():
    # Initialize the MCPToolkit with your configuration file
    mcp_toolkit = MCPToolkit(config_path="./mcp_servers_config.json")
    await mcp_toolkit.connect()

    # Get MCP tools
    tools = [*mcp_toolkit.get_tools()]

    # Optional: Print available tool names
    if tools:
        print(f"Available tools: {[tool.get_function_name() for tool in tools]}")
    else:
        print("No tools available from connected servers.")

    ollama_model = ModelFactory.create(
        model_platform=ModelPlatformType.OLLAMA,
        model_type="qwq:32b",
        url="http://localhost:11434/v1",  # Optional
        model_config_dict={"temperature": 0.4},
    )

    agent_sys_msg = (
        "You are a helpful assistant. Always use the provided external tools for filesystem operations "
        "Also remember to use the tools to answer questions about the filesystem. Always use the tools "
        "Make sure to keep the messages short and to the point so that tokens are not wasted. "
        "when asked, rather than relying on your internal knowledge. Ensure that your final answer does not "
        "end with any trailing whitespace."
    )

    agent = ChatAgent(agent_sys_msg, model=ollama_model, token_limit=32768, tools=tools)

    user_msg = "answer the following question using the tools: read all papers and summarize them"

    assistant_response = agent.step(user_msg)
    print(assistant_response.msg.content)

if __name__ == "__main__":
    loop = asyncio.new_event_loop()
    loop.run_until_complete(main())

mcp_servers_config.json

{
    "mcpServers": {
      "filesystem": {
        "command": "npx",
        "args": [
          "-y",
          "@modelcontextprotocol/server-filesystem",
          "./files"
        ]
      }
    }
}

FYI my uv pyproject.toml is like this. I am using camel-ai 0.2.45, which is new enough.

[project]
name = "test"
version = "0.1.0"
description = "Add your description here"
readme = "README.md"
requires-python = ">=3.12"
dependencies = [
  "camel-ai>=0.2.45",
  "mcp>=1.6.0",
  "numpy>=2.2.4",
  "pandas>=2.2.3",
  "pillow>=11.2.1",
  "polars>=1.20.0",
  "pyyaml>=6.0.2",
  "requests-oauthlib>=2.0.0",
  "ruff>=0.11.5",
  #"instructor[ollama]>=1.7.9",
]