Updates the state for multiple task instances simultaneously.
643 matches
67 actions
Airflow API (Stable)
67 actions
- Clear a DAG runPOSTv1.0.0
- Clear a set of task instancesPOSTv1.0.0
- Create a connectionPOSTv1.0.0
- Create a poolPOSTv1.0.0
- Create a rolePOSTv1.0.0
- Create a userPOSTv1.0.0
- Create a variablePOSTv1.0.0
- Delete a connectionDELETEv1.0.0
- Delete a DAGDELETEv1.0.0
- Delete a DAG runDELETEv1.0.0
- Delete a poolDELETEv1.0.0
- Delete a roleDELETEv1.0.0
- Delete a userDELETEv1.0.0
- Delete a variableDELETEv1.0.0
- Get a connectionGETv1.0.0
- Get a DAG runGETv1.0.0
- Get a datasetGETv1.0.0
- Get a list of loaded pluginsGETv1.0.0
- Get a log entryGETv1.0.0
- Get a mapped task instanceGETv1.0.0
- Get a poolGETv1.0.0
- Get a roleGETv1.0.0
- Get a simplified representation of DAGGETv1.0.0
- Get a source codeGETv1.0.0
- Get a task instanceGETv1.0.0
- Get a userGETv1.0.0
- Get a variableGETv1.0.0
- Get an XCom entryGETv1.0.0
- Get basic information about a DAGGETv1.0.0
- Get current configurationGETv1.0.0
- Get dataset eventsGETv1.0.0
- Get dataset events for a DAG runGETv1.0.0
- Get logsGETv1.0.0
- Get simplified representation of a taskGETv1.0.0
- Get tasks for DAGGETv1.0.0
- List connectionsGETv1.0.0
- List DAG runsGETv1.0.0
- List dag warningsGETv1.0.0
- List DAGsGETv1.0.0
- List datasetsGETv1.0.0
- List extra linksGETv1.0.0
- List log entriesGETv1.0.0
- List mapped task instancesGETv1.0.0
- List permissionsGETv1.0.0
- List poolsGETv1.0.0
- List providersGETv1.0.0
- List rolesGETv1.0.0
- List task instancesGETv1.0.0
- List usersGETv1.0.0
- List variablesGETv1.0.0
- List XCom entriesGETv1.0.0
- Modify a DAG runPATCHv1.0.0
- Set a state of task instancesPOSTv1.0.0
- Test a connectionPOSTv1.0.0
- Trigger a new DAG runPOSTv1.0.0
- Update a connectionPATCHv1.0.0
- Update a DAGPATCHv1.0.0
- Update a poolPATCHv1.0.0
- Update a rolePATCHv1.0.0
- Update a userPATCHv1.0.0
- Update a variablePATCHv1.0.0
- Update DAGsPATCHv1.0.0
- Update the DagRun note.PATCHv1.0.0
- Update the TaskInstance note.PATCHv1.0.0
- Update the TaskInstance note.PATCHv1.0.0
- Updates the state of a mapped task instancePATCHv1.0.0
- Updates the state of a task instancePATCHv1.0.0
Communication/Airflow API (Stable)
Set a state of task instances
v1.0.0Input
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
{
"type": "object",
"properties": {
"dag_run_id": {
"type": "string",
"description": "The task instance's DAG run ID. Either set this or execution_date but not both.\n\n*New in version 2.3.0*\n"
},
"dry_run": {
"type": "boolean",
"description": "If set, don't actually run this operation. The response will contain a list of task instances\nplanned to be affected, but won't be modified in any way.\n"
},
"execution_date": {
"type": "string",
"format": "datetime",
"description": "The execution date. Either set this or dag_run_id but not both."
},
"include_downstream": {
"type": "boolean",
"description": "If set to true, downstream tasks are also affected."
},
"include_future": {
"type": "boolean",
"description": "If set to True, also tasks from future DAG Runs are affected."
},
"include_past": {
"type": "boolean",
"description": "If set to True, also tasks from past DAG Runs are affected."
},
"include_upstream": {
"type": "boolean",
"description": "If set to true, upstream tasks are also affected."
},
"new_state": {
"type": "string",
"description": "Expected new state.",
"enum": [
"success",
"failed"
]
},
"task_id": {
"type": "string",
"description": "The task ID."
}
}
}Output
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
{
"type": "object",
"properties": {
"task_instances": {
"type": "array",
"items": {
"type": "object",
"properties": {
"dag_id": {
"type": "string",
"description": "The DAG ID."
},
"dag_run_id": {
"type": "string",
"description": "The DAG run ID."
},
"execution_date": {
"type": "string",
"format": "datetime"
},
"task_id": {
"type": "string",
"description": "The task ID."
}
}
}
}
}
}