get_import_error
Retrieve specific import errors from Apache Airflow clusters to diagnose and resolve DAG import failures during workflow execution.
Instructions
[Tool Role]: Retrieves a specific import error.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| import_error_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The handler function decorated with @mcp.tool() that implements the get_import_error tool. It fetches the specific import error details from the Airflow REST API using the provided import_error_id.
@mcp.tool() async def get_import_error(import_error_id: int) -> Dict[str, Any]: """[Tool Role]: Retrieves a specific import error.""" resp = await airflow_request("GET", f"/importErrors/{import_error_id}") resp.raise_for_status() return resp.json()