Microsoft Agent Framework

python -m pip install "agent-framework-core==1.23.0" "mcp==2.3.0" "tenacity==9.1.4"

import asyncio
import json
import os

os.environ["OTEL_SDK_DISABLED"] = "true"

from agent_framework import MCPStreamableHTTPTool


def metadata(contents):
    text = next(item.text for item in contents if item.type == "text" and item.text)
    data = json.loads(text)
    if not isinstance(data, dict):
        raise RuntimeError("Magic Hour returned unexpected metadata.")
    return data


async def check_project(api_key, project_id):
    async with MCPStreamableHTTPTool(
        name="magic_hour",
        url="https://mcp.magichour.ai/",
        static_headers={"Authorization": "Bearer " + api_key},
        load_prompts=False,
        request_timeout=30,
        terminate_on_close=True,
    ) as server:
        functions = {function.name: function for function in server.functions}
        print(f"Discovered {len(functions)} tools.")
        account = metadata(await functions["account_retrieve"].invoke(arguments={}))
        if not isinstance(account.get("id"), str) or not isinstance(account.get("credits"), int):
            raise RuntimeError("Magic Hour authorization returned unexpected account fields.")
        print("Magic Hour API authorization confirmed.")
        project = metadata(
            await functions["image_projects_retrieve_details"].invoke(
                arguments={"id": project_id}
            )
        )
        if project.get("id") != project_id or not isinstance(project.get("status"), str):
            raise RuntimeError("Project response did not match the saved job.")
        print("Image project status:", project["status"])
    return project["status"]


if __name__ == "__main__":
    asyncio.run(
        check_project(
            os.environ["MAGIC_HOUR_API_KEY"], os.environ["MAGIC_HOUR_IMAGE_PROJECT_ID"]
        )
    )