diff --git a/examples/client.py b/examples/client.py index 2cba0d3..7a0cc27 100644 --- a/examples/client.py +++ b/examples/client.py @@ -9,12 +9,12 @@ from acp import ( Client, - ClientSideConnection, connect_to_agent, RequestError, text_block, PROTOCOL_VERSION, ) +from acp.core import ClientSideConnection from acp.schema import ( AgentMessageChunk, AgentPlanUpdate, diff --git a/mkdocs.yml b/mkdocs.yml index 0464ad0..e74cd49 100644 --- a/mkdocs.yml +++ b/mkdocs.yml @@ -13,6 +13,7 @@ nav: - Use Cases: use-cases.md - Experimental Contrib: contrib.md - Releasing: releasing.md + - 0.7 Migration Guide: migration-guide-0.7.md plugins: - search - mkdocstrings: diff --git a/src/acp/agent/connection.py b/src/acp/agent/connection.py index 18a82dd..86bd29f 100644 --- a/src/acp/agent/connection.py +++ b/src/acp/agent/connection.py @@ -55,7 +55,7 @@ def __init__( to_agent: Callable[[Client], Agent] | Agent, input_stream: Any, output_stream: Any, - listening: bool = False, + listening: bool = True, **connection_kwargs: Any, ) -> None: agent = to_agent(cast(Client, self)) if callable(to_agent) else to_agent diff --git a/src/acp/core.py b/src/acp/core.py index dd6342e..a3d38b6 100644 --- a/src/acp/core.py +++ b/src/acp/core.py @@ -50,7 +50,7 @@ async def run_agent( if input_stream is None and output_stream is None: output_stream, input_stream = await stdio_streams() - conn = AgentSideConnection(agent, input_stream, output_stream, **connection_kwargs) + conn = AgentSideConnection(agent, input_stream, output_stream, listening=False, **connection_kwargs) await conn.listen()