get_task_instance_extra_links
Retrieve additional links for a specific task instance, such as monitoring dashboards or logs, by providing the DAG ID, DAG run ID, and task ID. Simplifies access to external resources within Apache Airflow clusters.
Instructions
[Tool Role]: Lists extra links for a specific task instance (e.g., monitoring dashboards, logs, external resources).
Args: dag_id: The DAG ID containing the task dag_run_id: The DAG run ID containing the task instance task_id: The task ID to get extra links for
Returns: List of extra links with their URLs and descriptions: task_id, dag_id, dag_run_id, extra_links
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes | ||
| dag_run_id | Yes | ||
| task_id | Yes |
Implementation Reference
- The main handler function for the 'get_task_instance_extra_links' tool, decorated with @mcp.tool() for registration. It makes an API request to retrieve extra links for the specified task instance.@mcp.tool() async def get_task_instance_extra_links(dag_id: str, dag_run_id: str, task_id: str) -> Dict[str, Any]: """[Tool Role]: Gets extra links for a task instance.""" resp = await airflow_request("GET", f"/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/links") resp.raise_for_status() return resp.json()