Airflow API (Stable)

Clear a DAG run

Clear a DAG run. *New in version 2.4.0*

Clear a set of task instances

Clears a set of task instances associated with the DAG for a specified date range.

Create a connection

Create a pool

Create a role

Create a new role. *New in version 2.1.0*

Create a user

Create a new user with unique username and email. *New in version 2.2.0*

Create a variable

Delete a connection

Delete a DAG

Deletes all metadata related to the DAG, including finished DAG Runs and Tasks. Logs are not deleted. This action cannot be undone. *New in version 2.2.0*

Delete a DAG run

Delete a pool

Delete a role

Delete a role. *New in version 2.1.0*

Delete a user

Delete a user with a specific username. *New in version 2.2.0*

Delete a variable

Get a connection

Get a DAG run

Get a dataset

Get a dataset by uri.

Get a list of loaded plugins

Get a list of loaded plugins. *New in version 2.1.0*

Get a log entry

Get a mapped task instance

Get details of a mapped task instance. *New in version 2.3.0*

Get a pool

Get a role

Get a role. *New in version 2.1.0*

Get a simplified representation of DAG

The response contains many DAG attributes, so the response can be large. If possible, consider using GET /dags/{dag_id}.

Get a source code

Get a source code using file token.

Get a task instance

Get a user

Get a user with a specific username. *New in version 2.1.0*

Get a variable

Get a variable by key.

Get an XCom entry

Get basic information about a DAG

Presents only information available in database (DAGModel). If you need detailed information, consider using GET /dags/{dag_id}/details.

Get current configuration

Get dataset events

Get dataset events

Get dataset events for a DAG run

Get datasets for a dag run. *New in version 2.4.0*

Get logs

Get logs for a specific task instance and its try number.

Get simplified representation of a task

Get tasks for DAG

List connections

List DAG runs

This endpoint allows specifying `~` as the dag_id to retrieve DAG runs for all DAGs.

List dag warnings

List DAGs

List DAGs in the database. `dag_id_pattern` can be set to match dags of a specific pattern

List datasets

List extra links

List extra links for task instance.

List log entries

List log entries from event log.

List mapped task instances

Get details of all mapped task instances. *New in version 2.3.0*

List permissions

Get a list of permissions. *New in version 2.1.0*

List pools

List providers

Get a list of providers. *New in version 2.1.0*

List roles

Get a list of roles. *New in version 2.1.0*

List task instances

This endpoint allows specifying `~` as the dag_id, dag_run_id to retrieve DAG runs for all DAGs and DAG runs.

List users

Get a list of users. *New in version 2.1.0*

List variables

The collection does not contain data. To get data, you must get a single entity.

List XCom entries

This endpoint allows specifying `~` as the dag_id, dag_run_id, task_id to retrieve XCOM entries for for all DAGs, DAG runs and task instances. XCom values won't be returned as they can be large. Use this endpoint to get a list of XCom entries and then fetch individual entry to get value.

Modify a DAG run

Modify a DAG run. *New in version 2.2.0*

Set a state of task instances

Updates the state for multiple task instances simultaneously.

Test a connection

Test a connection. *New in version 2.2.0*

Trigger a new DAG run

Update a connection

Update a DAG

Update a pool

Update a role

Update a role. *New in version 2.1.0*

Update a user

Update fields for a user. *New in version 2.2.0*

Update a variable

Update a variable by key.

Update DAGs

Update DAGs of a given dag_id_pattern using UpdateMask. This endpoint allows specifying `~` as the dag_id_pattern to update all DAGs. *New in version 2.3.0*

Update the DagRun note.

Update the manual user note of a DagRun. *New in version 2.5.0*

Update the TaskInstance note.

Update the manual user note of a mapped Task Instance. *New in version 2.5.0*

Update the TaskInstance note.

Update the manual user note of a non-mapped Task Instance. *New in version 2.5.0*

Updates the state of a mapped task instance

Updates the state for single mapped task instance. *New in version 2.5.0*

Updates the state of a task instance

Updates the state for single task instance. *New in version 2.5.0*