From 8496c2af36f81f5c8f8f60c8a450aeb19dec6ed0 Mon Sep 17 00:00:00 2001 From: cthomas Date: Fri, 6 Jun 2025 12:58:33 -0700 Subject: [PATCH] fix: multi agent test event loop (#2679) --- tests/test_multi_agent.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/test_multi_agent.py b/tests/test_multi_agent.py index 5571b0f0..e118f6a3 100644 --- a/tests/test_multi_agent.py +++ b/tests/test_multi_agent.py @@ -147,7 +147,7 @@ def manager_agent(server, actor): server.agent_manager.delete_agent(agent_scooby.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_empty_group(server, actor): group = server.group_manager.create_group( group=GroupCreate( @@ -172,7 +172,7 @@ async def test_empty_group(server, actor): server.group_manager.delete_group(group_id=group.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_modify_group_pattern(server, actor, participant_agents, manager_agent): group = server.group_manager.create_group( group=GroupCreate( @@ -196,7 +196,7 @@ async def test_modify_group_pattern(server, actor, participant_agents, manager_a server.group_manager.delete_group(group_id=group.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_list_agent_groups(server, actor, participant_agents): group_a = server.group_manager.create_group( group=GroupCreate( @@ -222,7 +222,7 @@ async def test_list_agent_groups(server, actor, participant_agents): server.group_manager.delete_group(group_id=group_b.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_round_robin(server, actor, participant_agents): description = ( "This is a group chat between best friends all like to hang out together. In their free time they like to solve mysteries." @@ -334,7 +334,7 @@ async def test_round_robin(server, actor, participant_agents): server.group_manager.delete_group(group_id=group.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_supervisor(server, actor, participant_agents): agent_scrappy = server.create_agent( request=CreateAgent( @@ -398,7 +398,7 @@ async def test_supervisor(server, actor, participant_agents): server.agent_manager.delete_agent(agent_id=agent_scrappy.id, actor=actor) -@pytest.mark.asyncio +@pytest.mark.asyncio(loop_scope="module") async def test_dynamic_group_chat(server, actor, manager_agent, participant_agents): description = ( "This is a group chat between best friends all like to hang out together. In their free time they like to solve mysteries."