unpause_dag
Resume scheduling for a paused Airflow DAG by specifying its ID, enabling new runs to execute efficiently without API complexity.
Instructions
[Tool Role]: Unpauses the specified Airflow DAG (allows scheduling new runs).
Args: dag_id: The DAG ID to unpause
Returns: Minimal info about the unpaused DAG: dag_id, is_paused
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes |
Implementation Reference
- The main handler function for the 'unpause_dag' tool. It uses the airflow_request to PATCH the DAG's pause status to False, confirming the update.@mcp.tool() async def unpause_dag(dag_id: str) -> Dict[str, Any]: """[Tool Role]: Unpauses the specified Airflow DAG (allows scheduling new runs).""" if not dag_id: raise ValueError("dag_id must not be empty") resp = await airflow_request("PATCH", f"/dags/{dag_id}", json={"is_paused": False}) resp.raise_for_status() dag_data = resp.json() return { "dag_id": dag_id, "is_paused": dag_data.get("is_paused") }
- src/mcp_airflow_api/tools/v1_tools.py:23-23 (registration)Registers the common tools including unpause_dag for v1 API by calling register_common_tools.common_tools.register_common_tools(mcp)
- src/mcp_airflow_api/tools/v2_tools.py:24-24 (registration)Registers the common tools including unpause_dag for v2 API by calling register_common_tools.common_tools.register_common_tools(mcp)