list_task_instances

list_task_instances

Retrieve task instances for a specific DAG run in Apache Airflow, filtering by parameters like duration, state, execution dates, and more for precise monitoring and analysis.

Instructions

List all task instances for a specific DAG run

Input Schema

Name	Required	Description
`dag_id`	Yes	The ID of the DAG
`dag_run_id`	Yes	The ID of the DAG run
`duration_gte`	No	Returns objects greater than or equal to the specified values
`duration_lte`	No	Returns objects less than or equal to the specified values
`end_date_gte`	No	Returns objects greater or equal the specified date
`end_date_lte`	No	Returns objects less than or equal to the specified date
`execution_date_gte`	No	Returns objects greater or equal to the specified date
`execution_date_lte`	No	Returns objects less than or equal to the specified date
`limit`	No	The numbers of items to return (default: 100)
`offset`	No	The number of items to skip before starting to collect the result set
`pool`	No	The value can be repeated to retrieve multiple matching values (OR condition)
`queue`	No	The value can be repeated to retrieve multiple matching values (OR condition)
`start_date_gte`	No	Returns objects greater or equal the specified date
`start_date_lte`	No	Returns objects less or equal the specified date
`state`	No	States of the task instance. The value can be repeated to retrieve multiple matching values (OR condition)
`updated_at_gte`	No	Returns objects greater or equal the specified date
`updated_at_lte`	No	Returns objects less or equal the specified date

Input Schema (JSON Schema)

{
  "properties": {
    "dag_id": {
      "description": "The ID of the DAG",
      "type": "string"
    },
    "dag_run_id": {
      "description": "The ID of the DAG run",
      "type": "string"
    },
    "duration_gte": {
      "description": "Returns objects greater than or equal to the specified values",
      "type": "number"
    },
    "duration_lte": {
      "description": "Returns objects less than or equal to the specified values",
      "type": "number"
    },
    "end_date_gte": {
      "description": "Returns objects greater or equal the specified date",
      "format": "date-time",
      "type": "string"
    },
    "end_date_lte": {
      "description": "Returns objects less than or equal to the specified date",
      "format": "date-time",
      "type": "string"
    },
    "execution_date_gte": {
      "description": "Returns objects greater or equal to the specified date",
      "format": "date-time",
      "type": "string"
    },
    "execution_date_lte": {
      "description": "Returns objects less than or equal to the specified date",
      "format": "date-time",
      "type": "string"
    },
    "limit": {
      "description": "The numbers of items to return (default: 100)",
      "minimum": 1,
      "type": "integer"
    },
    "offset": {
      "description": "The number of items to skip before starting to collect the result set",
      "minimum": 0,
      "type": "integer"
    },
    "pool": {
      "description": "The value can be repeated to retrieve multiple matching values (OR condition)",
      "items": {
        "type": "string"
      },
      "type": "array"
    },
    "queue": {
      "description": "The value can be repeated to retrieve multiple matching values (OR condition)",
      "items": {
        "type": "string"
      },
      "type": "array"
    },
    "start_date_gte": {
      "description": "Returns objects greater or equal the specified date",
      "format": "date-time",
      "type": "string"
    },
    "start_date_lte": {
      "description": "Returns objects less or equal the specified date",
      "format": "date-time",
      "type": "string"
    },
    "state": {
      "description": "States of the task instance. The value can be repeated to retrieve multiple matching values (OR condition)",
      "items": {
        "type": "string"
      },
      "type": "array"
    },
    "updated_at_gte": {
      "description": "Returns objects greater or equal the specified date",
      "format": "date-time",
      "type": "string"
    },
    "updated_at_lte": {
      "description": "Returns objects less or equal the specified date",
      "format": "date-time",
      "type": "string"
    }
  },
  "required": [
    "dag_id",
    "dag_run_id"
  ],
  "type": "object"
}

MCP Server for Apache Airflow

Instructions

Input Schema

Input Schema (JSON Schema)

Other Tools from MCP Server for Apache Airflow

Related Tools

MCP directory API