Airflow API (Stable)

apache · Company

Company No Auth Free & Open messaging

# Overview To facilitate management, Apache Airflow supports a range of REST API endpoints across its objects. This section provides an overview of the API design, methods, and supported use cases. Most of the endpoints accept `JSON` as input and return `JSON` responses. This means that you must usually add the following headers to your request: ``` Content-type: application/json Accept: application/json ``` ## Resources The term `resource` refers to a single type of object in the Airflow me

Authentication

No authentication requiredFree to use with no key needed.

Sample Requests

GET List dag warnings

List dag warnings

https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings?limit=100&dag_id=example&offset=0&order_by=example&warning_type=example

Hover any highlighted part to learn what it does

curl -X GET "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings?limit=100&dag_id=example&offset=0&order_by=example&warning_type=example"

import requests
params = {
    "limit": "100",
    "dag_id": "example",
    "offset": "0",
    "order_by": "example",
    "warning_type": "example"
}
response = requests.get(
    "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings",
    params=params,
)
print(response.json())

const url = new URL('https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings');
url.searchParams.set('limit', '100');
url.searchParams.set('dag_id', 'example');
url.searchParams.set('offset', '0');
url.searchParams.set('order_by', 'example');
url.searchParams.set('warning_type', 'example');

const response = await fetch(url); 
const data = await response.json();
console.log(data);

package main

import (
	"fmt"
	"io"
	"net/http"
	"net/url"
)

func main() {
	baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings")
	q := baseURL.Query()
	q.Set("limit", "100")
	q.Set("dag_id", "example")
	q.Set("offset", "0")
	q.Set("order_by", "example")
	q.Set("warning_type", "example")
	baseURL.RawQuery = q.Encode()
	targetURL := baseURL.String()
	req, _ := http.NewRequest("GET", targetURL, nil)

	client := &http.Client{}
	resp, _ := client.Do(req)
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	fmt.Println(string(body))
}

require "net/http"
require "json"

uri = URI("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings")
uri.query = URI.encode_www_form({
  "limit" => "100",
  "dag_id" => "example",
  "offset" => "0",
  "order_by" => "example",
  "warning_type" => "example"
})

http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"

req = Net::HTTP::Get.new(uri)

res = http.request(req)
puts JSON.parse(res.body)

<?php
$url = "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dagWarnings?" . http_build_query([
    "limit" => "100",
    "dag_id" => "example",
    "offset" => "0",
    "order_by" => "example",
    "warning_type" => "example"
]);
$opts = ["http" => [
    "method" => "GET",
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));

GET List DAGs

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

https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags?tags=example&limit=100&offset=0&order_by=example&only_active=true&dag_id_pattern=example

Hover any highlighted part to learn what it does

curl -X GET "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags?tags=example&limit=100&offset=0&order_by=example&only_active=true&dag_id_pattern=example"

import requests
params = {
    "tags": "example",
    "limit": "100",
    "offset": "0",
    "order_by": "example",
    "only_active": "true",
    "dag_id_pattern": "example"
}
response = requests.get(
    "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags",
    params=params,
)
print(response.json())

const url = new URL('https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags');
url.searchParams.set('tags', 'example');
url.searchParams.set('limit', '100');
url.searchParams.set('offset', '0');
url.searchParams.set('order_by', 'example');
url.searchParams.set('only_active', 'true');
url.searchParams.set('dag_id_pattern', 'example');

const response = await fetch(url); 
const data = await response.json();
console.log(data);

package main

import (
	"fmt"
	"io"
	"net/http"
	"net/url"
)

func main() {
	baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags")
	q := baseURL.Query()
	q.Set("tags", "example")
	q.Set("limit", "100")
	q.Set("offset", "0")
	q.Set("order_by", "example")
	q.Set("only_active", "true")
	q.Set("dag_id_pattern", "example")
	baseURL.RawQuery = q.Encode()
	targetURL := baseURL.String()
	req, _ := http.NewRequest("GET", targetURL, nil)

	client := &http.Client{}
	resp, _ := client.Do(req)
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	fmt.Println(string(body))
}

require "net/http"
require "json"

uri = URI("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags")
uri.query = URI.encode_www_form({
  "tags" => "example",
  "limit" => "100",
  "offset" => "0",
  "order_by" => "example",
  "only_active" => "true",
  "dag_id_pattern" => "example"
})

http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"

req = Net::HTTP::Get.new(uri)

res = http.request(req)
puts JSON.parse(res.body)

<?php
$url = "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/dags?" . http_build_query([
    "tags" => "example",
    "limit" => "100",
    "offset" => "0",
    "order_by" => "example",
    "only_active" => "true",
    "dag_id_pattern" => "example"
]);
$opts = ["http" => [
    "method" => "GET",
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));

GET List datasets

List datasets

https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets?limit=100&offset=0&order_by=example&uri_pattern=example

Hover any highlighted part to learn what it does

curl -X GET "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets?limit=100&offset=0&order_by=example&uri_pattern=example"

import requests
params = {
    "limit": "100",
    "offset": "0",
    "order_by": "example",
    "uri_pattern": "example"
}
response = requests.get(
    "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets",
    params=params,
)
print(response.json())

const url = new URL('https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets');
url.searchParams.set('limit', '100');
url.searchParams.set('offset', '0');
url.searchParams.set('order_by', 'example');
url.searchParams.set('uri_pattern', 'example');

const response = await fetch(url); 
const data = await response.json();
console.log(data);

package main

import (
	"fmt"
	"io"
	"net/http"
	"net/url"
)

func main() {
	baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets")
	q := baseURL.Query()
	q.Set("limit", "100")
	q.Set("offset", "0")
	q.Set("order_by", "example")
	q.Set("uri_pattern", "example")
	baseURL.RawQuery = q.Encode()
	targetURL := baseURL.String()
	req, _ := http.NewRequest("GET", targetURL, nil)

	client := &http.Client{}
	resp, _ := client.Do(req)
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	fmt.Println(string(body))
}

require "net/http"
require "json"

uri = URI("https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets")
uri.query = URI.encode_www_form({
  "limit" => "100",
  "offset" => "0",
  "order_by" => "example",
  "uri_pattern" => "example"
})

http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"

req = Net::HTTP::Get.new(uri)

res = http.request(req)
puts JSON.parse(res.body)

<?php
$url = "https://api.apis.guru/v2/specs/apache.org/airflow/2.5.1/datasets?" . http_build_query([
    "limit" => "100",
    "offset" => "0",
    "order_by" => "example",
    "uri_pattern" => "example"
]);
$opts = ["http" => [
    "method" => "GET",
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));

Postman Setup Guide

Get Postman ↗

See official documentation for authentication and setup.

What can you build with Airflow API (Stable)?

Airflow API (Stable) is a Company API. Developers commonly use company APIs for:

enriching CRM records with company firmographics
building lead-generation and prospecting tools
verifying business identity and registration details
monitoring competitors and market intelligence
powering B2B data enrichment pipelines

No authentication required. This API is open — no signup or key needed. Ideal for quick prototypes and public-facing features. Airflow API (Stable) is free to use, making it a low-risk choice to experiment with.

New to APIs? Read our beginner's guide · Learn about API keys · What is REST?

Open documentation ↗