# ============================
# == MCP client integration ==
# ============================

# Stubbed out MCP client for local testing
async def init_mcp():
    print("MCP client (mock) initialized.")

async def notify_agents(event_data: dict):
    print(f"[MCP MOCK] Notifying Forecast/Anomaly agents: {event_data}")
