MCP-Airflow-API

Instructions

Implementation Reference

• src/mcp_airflow_api/tools/common_tools.py:644-671 (handler)

  The handler function for the 'search_config_options' tool. It fetches the full Airflow config via API, searches for options matching the search_term in names and values, and returns structured matches grouped by config sections.
  @mcp.tool() async def search_config_options(search_term: str) -> Dict[str, Any]: """[Tool Role]: Searches for configuration options matching a term.""" try: resp = await airflow_request("GET", "/config") resp.raise_for_status() config_data = resp.json() matching_options = {} for section_name, section_data in config_data.get("sections", {}).items(): section_matches = {} for option_name, option_data in section_data.get("options", {}).items(): if search_term.lower() in option_name.lower() or search_term.lower() in str(option_data.get("value", "")).lower(): section_matches[option_name] = option_data if section_matches: matching_options[section_name] = section_matches return { "search_term": search_term, "matching_options": matching_options, "total_matches": sum(len(section) for section in matching_options.values()) } except Exception as e: return { "error": f"Configuration access denied: {str(e)}", "note": "This requires 'expose_config = True' in airflow.cfg [webserver] section" }
• src/mcp_airflow_api/tools/common_tools.py:644-644 (registration)

  The @mcp.tool() decorator registers the search_config_options function as an MCP tool within the register_common_tools function.
  @mcp.tool()