from autogen_agentchat.agents import AssistantAgentfrom synap_autogen import SynapSearchTool, SynapStoreTooltools = [ SynapSearchTool(sdk=sdk, user_id="alice", customer_id="acme"), SynapStoreTool(sdk=sdk, user_id="alice", customer_id="acme"),]agent = AssistantAgent( name="MemoryAgent", model_client=your_model_client, tools=tools, system_message="Use synap_search to recall user context. Use synap_store to remember new information.",)await agent.run(task="What are my top priorities this week?")
from autogen_core import CancellationTokentoken = CancellationToken()result = await tool.run({"query": "project deadlines"}, cancellation_token=token)# Cancel from elsewhere in the same asyncio task group:token.cancel()