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()