This document demonstrates how to integrate the Pica MCP server with OpenAI’s Agents SDK.

​
GitHub Repository

@picahq/awesome-pica

Check out our GitHub repository to explore the code, contribute, or raise issues.

​
Example Use Cases

In this section, we’ll walk through some example use cases that you can use to get started with the OpenAI Agents SDK and Pica MCP.

Start by installing the dependencies:

pip install openai-agents pica-ai

import asyncio
import os
from agents import Agent, Runner
from agents.mcp import MCPUtil, MCPServerStdio, MCPServerStdioParams
from dotenv import load_dotenv
from pica_ai import PicaClient, PicaClientOptions

load_dotenv()

async def use_pica_mcp():
    pica_secret = os.getenv("PICA_SECRET")

    if not pica_secret:
        raise ValueError("PICA_SECRET environment variable is not set")

    pica = PicaClient(
        secret=pica_secret, 
        options=PicaClientOptions(
            connectors=["*"],
        )
    )

    system_prompt = pica.generate_system_prompt()

    params = MCPServerStdioParams({
        "command": "npx",
        "args": ["-y", "@picahq/pica-mcp"],
        "env": {"PICA_SECRET": pica_secret}
    })
    
    try:
        async with MCPServerStdio(
            params=params,
            cache_tools_list=True,
            name="Pica MCP Server"
        ) as server:
            server.invalidate_tools_cache()
            agent_tools = await MCPUtil.get_function_tools(server)
            
            # Create an agent with MCP tools
            mcp_agent = Agent(
                name="Assistant with Pica",
                instructions=system_prompt,
                tools=agent_tools,
                model="gpt-4o",
                tool_use_behavior="run_llm_again",
                mcp_servers=[server]
            )
            
            # Run the agent with tools and the action logger
            mcp_result = await Runner.run(
                starting_agent=mcp_agent, 
                input="What connections do I have in access to?",
                max_turns=20
            )

            print(mcp_result.final_output)
            
    except Exception as e:
        print(f"Error running Pica MCP server: {e}")

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