list_task_instances_all
Retrieve task instances across all DAGs or specific DAGs with advanced filtering by date, duration, state, pool, queue, and pagination options for Airflow cluster monitoring.
Instructions
[Tool Role]: Lists task instances across all DAGs or filtered by specific DAG with comprehensive filtering options.
IMPORTANT: When users provide natural language dates, calculate relative dates using the current server time context (internally via get_current_time_context):
- "yesterday" = current_date - 1 day
- "last week" = current_date - 7 days to current_date - 1 day
- "last 3 days" = current_date - 3 days to current_date
- "today" = current_date
Args: dag_id: Filter by DAG ID (optional) dag_run_id: Filter by DAG run ID (optional) execution_date_gte: Filter by execution date greater than or equal to (ISO 8601 format with timezone, e.g., '2024-01-01T00:00:00Z', optional) execution_date_lte: Filter by execution date less than or equal to (ISO 8601 format with timezone, e.g., '2024-01-01T23:59:59Z', optional) start_date_gte: Filter by start date greater than or equal to (ISO 8601 format with timezone, optional) start_date_lte: Filter by start date less than or equal to (ISO 8601 format with timezone, optional) end_date_gte: Filter by end date greater than or equal to (ISO 8601 format with timezone, optional) end_date_lte: Filter by end date less than or equal to (ISO 8601 format with timezone, optional) duration_gte: Filter by duration greater than or equal to (seconds, optional) duration_lte: Filter by duration less than or equal to (seconds, optional) state: Filter by task state (queued, running, success, failed, up_for_retry, up_for_reschedule, upstream_failed, skipped, deferred, scheduled, removed, restarting, optional) pool: Filter by pool name (optional) queue: Filter by queue name (optional) limit: Maximum number of task instances to return (default: 20) offset: Number of task instances to skip for pagination (default: 0)
Returns: List of task instances with comprehensive information: task_instances, total_entries, limit, offset
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | No | ||
| dag_run_id | No | ||
| duration_gte | No | ||
| duration_lte | No | ||
| end_date_gte | No | ||
| end_date_lte | No | ||
| execution_date_gte | No | ||
| execution_date_lte | No | ||
| limit | No | ||
| offset | No | ||
| pool | No | ||
| queue | No | ||
| start_date_gte | No | ||
| start_date_lte | No | ||
| state | No |