pip install git+ssh://git@github.com/openai/swarm.git

from swarm import Swarm, Agentclient = Swarm()def transfer_to_agent_b():    return agent_bagent_a = Agent(    name="Agent A",    instructions="你是一个有用的助手",    functions=[transfer_to_agent_b],)agent_b = Agent(    name="Agent B",    instructions="仅仅使用繁体字说话",)response = client.run(    agent=agent_a,    messages=[{"role": "user", "content": "我想和Agent B说话"}],)print("User和AgentA说: 我想和Agent B说话。")print("Agent：",response.messages[-1]["content"])

client = Swarm() #创建了Swarm客户端

def transfer_to_agent_b():    return agent_b    agent_a = Agent(    name="Agent A",    instructions="你是一个有用的助手",  functions=[transfer_to_agent_b], #Agent A被赋予了一个特殊的函数transfer_to_agent_b。)
agent_b = Agent(    name="Agent B",    instructions="仅仅使用繁体字说话",)

response = client.run(    agent=agent_a,    messages=[{"role": "user", "content": "我想和Agent B说话"}],)

源代码 core.py/run 函数：def run(self,agent: Agent,messages: List,context_variables: dict = {},model_override: str = None,stream: bool = False,debug: bool = False,max_turns: int = float("inf"),execute_tools: bool = True,) -> Response:if stream:return self.run_and_stream(agent=agent,messages=messages,context_variables=context_variables,model_override=model_override,debug=debug,max_turns=max_turns,execute_tools=execute_tools,)active_agent = agentcontext_variables = copy.deepcopy(context_variables)history = copy.deepcopy(messages)init_len = len(messages)
while len(history) - init_len < max_turns and active_agent:# get completion with current history, agentcompletion = self.get_chat_completion(agent=active_agent,history=history,context_variables=context_variables,model_override=model_override,stream=stream,debug=debug,)message = completion.choices[0].messagedebug_print(debug, "Received completion:", message)message.sender = active_agent.namehistory.append(json.loads(message.model_dump_json()))# to avoid OpenAI types (?)
if not message.tool_calls or not execute_tools:debug_print(debug, "Ending turn.")break
# handle function calls, updating context_variables, and switching agentspartial_response = self.handle_tool_calls(message.tool_calls, active_agent.functions, context_variables, debug)history.extend(partial_response.messages)context_variables.update(partial_response.context_variables)if partial_response.agent:active_agent = partial_response.agent
return Response(messages=history[init_len:],agent=active_agent,context_variables=context_variables,)

while len(history) - init_len < max_turns and active_agent:

if partial_response.agent:    active_agent = partial_response.agent