pipedream_linkedin.py
"""
Pipedream LinkedIn MCP
This example shows how to use Pipedream MCP servers (in this case the LinkedIn one) with Agno Agents.
1. Connect your Pipedream and LinkedIn accounts: https://mcp.pipedream.com/app/linkedin
2. Get your Pipedream MCP server url: https://mcp.pipedream.com/app/linkedin
3. Set the MCP_SERVER_URL environment variable to the MCP server url you got above
4. Install dependencies: uv pip install agno mcp
"""
import asyncio
import os
from agno.agent import Agent
from agno.models.openai import OpenAIChat
from agno.tools.mcp import MCPTools
from agno.utils.log import log_exception
# ---------------------------------------------------------------------------
# Create Agent
# ---------------------------------------------------------------------------
mcp_server_url = os.getenv("MCP_SERVER_URL")
async def run_agent(task: str) -> None:
try:
async with MCPTools(
url=mcp_server_url, transport="sse", timeout_seconds=20
) as mcp:
agent = Agent(
model=OpenAIChat(id="gpt-5.2"),
tools=[mcp],
markdown=True,
)
await agent.aprint_response(input=task, stream=True)
except Exception as e:
log_exception(f"Unexpected error: {e}")
# ---------------------------------------------------------------------------
# Run Agent
# ---------------------------------------------------------------------------
if __name__ == "__main__":
asyncio.run(
run_agent("Check the Pipedream organization on LinkedIn and tell me about it")
)
Current Status
This v2.7.2 example uses Pipedream’s retired per-app SSE URL. It cannot connect to the current Pipedream MCP service without code and authentication changes. See Pipedream MCP for the current end-user and developer flows.