beapirate

import asyncio
import threading
import queue
import dspy
from mcp import ClientSession, StdioServerParameters
from mcp.client.stdio import stdio_client


class ToolManager:
    def __init__(self, server_params):