get_task_instance_extra_links
Retrieve additional links for Airflow task instances to access logs, documentation, or external resources associated with specific DAG runs and tasks.
Instructions
[Tool Role]: Gets extra links for a task instance.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes | ||
| dag_run_id | Yes | ||
| task_id | Yes |
Output Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- The handler function decorated with @mcp.tool() that implements the tool logic by querying the Airflow API for extra links of a specific task instance.
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()