clear_task_instances

Clear specified task instances in Apache Airflow. Manage DAG task execution by removing instances within defined parameters, including date ranges, subdags, and upstream/downstream dependencies.

Instructions

Clear a set of task instances

Input Schema

Name	Required	Description	Default
`dag_id`	Yes
`dry_run`	No
`end_date`	No
`include_downstream`	No
`include_future`	No
`include_parentdag`	No
`include_past`	No
`include_subdags`	No
`include_upstream`	No
`reset_dag_runs`	No
`start_date`	No
`task_ids`	No

Input Schema (JSON Schema)

{
  "properties": {
    "dag_id": {
      "title": "Dag Id",
      "type": "string"
    },
    "dry_run": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dry Run"
    },
    "end_date": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "End Date"
    },
    "include_downstream": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Downstream"
    },
    "include_future": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Future"
    },
    "include_parentdag": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Parentdag"
    },
    "include_past": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Past"
    },
    "include_subdags": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Subdags"
    },
    "include_upstream": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Include Upstream"
    },
    "reset_dag_runs": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Reset Dag Runs"
    },
    "start_date": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Start Date"
    },
    "task_ids": {
      "anyOf": [
        {
          "items": {
            "type": "string"
          },
          "type": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Task Ids"
    }
  },
  "required": [
    "dag_id"
  ],
  "title": "clear_task_instancesArguments",
  "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