list_task_instances_all
List task instances with filters for DAG, run, task, dates, duration, state, and pool to monitor and troubleshoot Airflow workflows.
Instructions
[Tool Role]: Lists task instances with comprehensive filtering options.
Args: dag_id: Exact DAG identifier, as returned by list_dags; not its display name. Default: None. dag_run_id: Exact DAG run identifier for the selected DAG. Default: None. task_id: Exact task identifier within the selected DAG. Default: None. execution_date_gte: Optional inclusive task execution time lower bound, in ISO 8601 format. Default: None. execution_date_lte: Optional inclusive task execution time upper bound, in ISO 8601 format. Default: None. start_date_gte: Optional inclusive task start time lower bound, in ISO 8601 format. Default: None. start_date_lte: Optional inclusive task start time upper bound, in ISO 8601 format. Default: None. end_date_gte: Optional inclusive task end time lower bound, in ISO 8601 format. Default: None. end_date_lte: Optional inclusive task end time upper bound, in ISO 8601 format. Default: None. duration_gte: Optional minimum task duration in seconds. Default: None. duration_lte: Optional maximum task duration in seconds. Default: None. state: Optional list of task states, such as ["failed", "running"]. Default: None. pool: Optional list of Airflow pool names to filter task instances. Default: None. limit: Maximum number of records to request per page. Default: 100. offset: Number of records to skip for pagination. Default: 0.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| pool | No | ||
| limit | No | ||
| state | No | ||
| dag_id | No | ||
| offset | No | ||
| task_id | No | ||
| dag_run_id | No | ||
| duration_gte | No | ||
| duration_lte | No | ||
| end_date_gte | No | ||
| end_date_lte | No | ||
| start_date_gte | No | ||
| start_date_lte | No | ||
| execution_date_gte | No | ||
| execution_date_lte | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||