set_task_instances_state
Change the state of Airflow task instances to manage workflow execution, pause tasks, or resume processing within DAGs.
Instructions
Set a state of task instances
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dag_id | Yes | ||
| dry_run | No | ||
| execution_date | No | ||
| include_downstream | No | ||
| include_future | No | ||
| include_past | No | ||
| include_upstream | No | ||
| state | Yes | ||
| 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"
},
"execution_date": {
"anyOf": [
{
"type": "string"
},
{
"type": "null"
}
],
"default": null,
"title": "Execution 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_past": {
"anyOf": [
{
"type": "boolean"
},
{
"type": "null"
}
],
"default": null,
"title": "Include Past"
},
"include_upstream": {
"anyOf": [
{
"type": "boolean"
},
{
"type": "null"
}
],
"default": null,
"title": "Include Upstream"
},
"state": {
"title": "State",
"type": "string"
},
"task_ids": {
"anyOf": [
{
"items": {
"type": "string"
},
"type": "array"
},
{
"type": "null"
}
],
"default": null,
"title": "Task Ids"
}
},
"required": [
"dag_id",
"state"
],
"type": "object"
}