import asyncio
from mcp import ClientSession, StdioServerParameters
from mcp.client.http import HttpClientTransport

async def main():
    async with HttpClientTransport("http://10.100.0.17:8000/mcp/") as transport:
        async with ClientSession(transport) as session:
            await session.initialize()
            
            # Clear failures
            result = await session.call_tool("clear_queue_failures", {})
            print(f"Clear Failures: {result}")
            
            # Add memory
            result = await session.call_tool("add_memory", {
                "name": "MCP Health Verification - 2026-01-11",
                "episode_body": "Graphiti MCP server audit completed. Server healthy, queue cleared. Pending: SEMAPHORE_LIMIT and timeout changes require scheduled maintenance window.",
                "group_id": "global"
            })
            print(f"Add Memory: {result}")
            
            # Get status
            result = await session.call_tool("get_queue_status", {})
            print(f"Queue Status: {result}")

if __name__ == "__main__":
    asyncio.run(main())