get_dag
Retrieve detailed information about a specific Apache Airflow DAG in Amazon MWAA environments, including schedule, tags, and current state.
Instructions
Get details about a specific DAG.
Args: environment_name: Name of the MWAA environment dag_id: The DAG ID
Returns: Dictionary containing DAG details including schedule, tags, and state
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment_name | Yes | ||
| dag_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- awslabs/mwaa_mcp_server/tools.py:275-277 (handler)The actual implementation of the get_dag tool, which calls the Airflow API.
async def get_dag(self, environment_name: str, dag_id: str) -> Dict[str, Any]: """Get DAG details via Airflow API.""" return self._invoke_airflow_api(environment_name, "GET", f"/dags/{dag_id}") - awslabs/mwaa_mcp_server/server.py:278-292 (registration)The registration of the get_dag tool in the MCP server and its wrapper function.
@mcp.tool(name="get_dag") async def get_dag( environment_name: str, dag_id: str, ) -> Dict[str, Any]: """Get details about a specific DAG. Args: environment_name: Name of the MWAA environment dag_id: The DAG ID Returns: Dictionary containing DAG details including schedule, tags, and state """ return await tools.get_dag(environment_name, dag_id)