post_clear_task_instances

Clear and reset task instances in Airflow using specified criteria like DAG ID, task IDs, and time ranges. Supports optional parameters for downstream, upstream, parent DAGs, subdags, and dry runs.

Instructions

Input Schema

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

Input Schema (JSON Schema)

{
  "properties": {
    "dag_id": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dag Id"
    },
    "dag_run_id": {
      "anyOf": [
        {
          "type": "string"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Dag Run Id"
    },
    "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"
    },
    "only_failed": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Only Failed"
    },
    "only_running": {
      "anyOf": [
        {
          "type": "boolean"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Only Running"
    },
    "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": "array"
        },
        {
          "type": "null"
        }
      ],
      "default": null,
      "title": "Task Ids"
    }
  },
  "title": "post_clear_task_instances_input",
  "type": "object"
}

airflow-mcp-server

post_clear_task_instances

Instructions

Input Schema

Input Schema (JSON Schema)

Other Tools from airflow-mcp-server

Related Tools

MCP directory API