mirror of
https://github.com/microsoft/autogen.git
synced 2025-08-03 14:22:34 +00:00
36 lines
1.1 KiB
Python
36 lines
1.1 KiB
Python
![]() |
import asyncio
|
||
|
import autogen
|
||
|
import pytest
|
||
|
from test_assistant_agent import KEY_LOC, OAI_CONFIG_LIST
|
||
|
|
||
|
|
||
|
@pytest.mark.asyncio
|
||
|
async def test_async_get_human_input():
|
||
|
try:
|
||
|
import openai
|
||
|
except ImportError:
|
||
|
return
|
||
|
config_list = autogen.config_list_from_json(OAI_CONFIG_LIST, KEY_LOC)
|
||
|
|
||
|
# create an AssistantAgent instance named "assistant"
|
||
|
assistant = autogen.AssistantAgent(
|
||
|
name="assistant",
|
||
|
max_consecutive_auto_reply=2,
|
||
|
llm_config={"request_timeout": 600, "seed": 41, "config_list": config_list, "temperature": 0},
|
||
|
)
|
||
|
|
||
|
user_proxy = autogen.UserProxyAgent(name="user", human_input_mode="ALWAYS", code_execution_config=False)
|
||
|
|
||
|
async def custom_a_get_human_input(prompt):
|
||
|
return "This is a test"
|
||
|
|
||
|
user_proxy.a_get_human_input = custom_a_get_human_input
|
||
|
|
||
|
user_proxy.register_reply([autogen.Agent, None], autogen.ConversableAgent.a_check_termination_and_human_reply)
|
||
|
|
||
|
await user_proxy.a_initiate_chat(assistant, clear_history=True, message="Hello.")
|
||
|
|
||
|
|
||
|
if __name__ == "__main__":
|
||
|
test_async_get_human_input()
|