MCP Server for Apache Airflow

list_task_instances

List all task instances for a specific DAG run

Input Schema

NameRequiredDescriptionDefault
dag_idYesThe ID of the DAG
dag_run_idYesThe ID of the DAG run
duration_gteNoReturns objects greater than or equal to the specified values
duration_lteNoReturns objects less than or equal to the specified values
end_date_gteNoReturns objects greater or equal the specified date
end_date_lteNoReturns objects less than or equal to the specified date
execution_date_gteNoReturns objects greater or equal to the specified date
execution_date_lteNoReturns objects less than or equal to the specified date
limitNoThe numbers of items to return (default: 100)
offsetNoThe number of items to skip before starting to collect the result set
poolNoThe value can be repeated to retrieve multiple matching values (OR condition)
queueNoThe value can be repeated to retrieve multiple matching values (OR condition)
start_date_gteNoReturns objects greater or equal the specified date
start_date_lteNoReturns objects less or equal the specified date
stateNoStates of the task instance. The value can be repeated to retrieve multiple matching values (OR condition)
updated_at_gteNoReturns objects greater or equal the specified date
updated_at_lteNoReturns 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" }