fix linux test

docs/sphinx_doc/en/source/tutorial/208-distribute.md

@@ -228,7 +228,7 @@ This process has a potential issue: the original agent is initialized twice, onc
     ```
 
 ```{note}
-Some IDEs might display a hint indicating that the `to_dist` parameter does not exist, but this will not cause an error at runtime. 
+Some IDEs might display a hint indicating that the `to_dist` parameter does not exist, but this will not cause an error at runtime.
 Additionally, if the `to_dist` parameter has already been passed in the initialization parameters, the `to_dist` method should not be called again.
 ```
 

src/agentscope/_init.py

@@ -1,6 +1,7 @@
 # -*- coding: utf-8 -*-
 """The init function for the package."""
 import json
+import multiprocessing
 from typing import Optional, Union, Sequence
 from agentscope import agents
 from .agents import AgentBase
@@ -76,6 +77,10 @@ def init(
         studio_url (`Optional[str]`, defaults to `None`):
             The url of the agentscope studio.
     """
+    # set the multiprocessing start method
+    start_method = multiprocessing.get_start_method()
+    if start_method != "spawn":
+        multiprocessing.set_start_method("spawn", force=True)
     # Init the runtime
     ASManager.get_instance().initialize(
         model_configs=model_configs,

src/agentscope/rpc/rpc_object.py

@@ -15,7 +15,7 @@
 
 from .rpc_agent_client import RpcAgentClient, call_func_in_thread
 from .rpc_async import AsyncResult
-from ..exception import AgentCreationError
+from ..exception import AgentCreationError, AgentServerNotAliveError
 
 
 def get_public_methods(cls: type) -> list[str]:
@@ -97,9 +97,12 @@ def __init__(
                 studio_url=studio_url,  # type: ignore[arg-type]
             )
             self._launch_server()
-        self.client = RpcAgentClient(self.host, self.port)
+        else:
+            self.client = RpcAgentClient(self.host, self.port)
         if not connect_existing:
             self.create(configs)
+            if launch_server:
+                self._check_created()
         else:
             self._creating_stub = None
 
@@ -136,6 +139,8 @@ def _launch_server(self) -> None:
             host=self.host,
             port=self.port,
         )
+        if not self.client.is_alive():
+            raise AgentServerNotAliveError(self.host, self.port)
 
     def stop(self) -> None:
         """Stop the RpcAgent and the rpc server."""

src/agentscope/server/servicer.py

@@ -445,7 +445,7 @@ def _process_task(
             args = None
         agent = self.get_agent(agent_id)
         if isinstance(args, AsyncResult):
-            args._fetch_result()  # pylint: disable=W0212
+            args = args.result()  # pylint: disable=W0212
         try:
             if target_func == "reply":
                 result = getattr(agent, target_func)(args)