airflow.providers.common.ai.example_dags.example_mcp¶

Example DAGs demonstrating MCP server integration with AgentOperator.

Attributes¶

`example_mcp_toolset`()	Use an MCP server configured via an Airflow connection.
`example_mcp_multiple_servers`()	Combine multiple MCP servers with prefixes to avoid tool name collisions.
`example_mcp_filtered_tools`()	Offer the agent only the MCP tools the Dag author listed.
`example_mcp_stdio_env_provider`()	Use a stdio MCP server whose subprocess needs a secret from another connection.

airflow.providers.common.ai.example_dags.example_mcp.example_mcp_toolset()[source]¶: Use an MCP server configured via an Airflow connection.

airflow.providers.common.ai.example_dags.example_mcp.example_mcp_multiple_servers()[source]¶: Combine multiple MCP servers with prefixes to avoid tool name collisions.

airflow.providers.common.ai.example_dags.example_mcp.READ_ONLY_WEATHER_TOOLS[source]¶

airflow.providers.common.ai.example_dags.example_mcp.example_mcp_filtered_tools()[source]¶: Offer the agent only the MCP tools the Dag author listed.

airflow.providers.common.ai.example_dags.example_mcp.example_mcp_stdio_env_provider()[source]¶: Use a stdio MCP server whose subprocess needs a secret from another connection.