comrades, i did a pilot on a python sdk based on the Airflow 2.0.0 stable API
source code
pypi package
i’m using this repo to track changes on this file. once we finalize the changes, i’ll write a python script to load in the yaml file and apply the changes automatically whenever the openapi spec is updated. eventually, i’ll contribute it to the community here
right now get_dags
is the only endpoint i tested
i’ll be updating this python sdk frequently since my team is going to use it frequently
and i’m hoping we can test all endpoints via crowd-sourcing
"""
Example
"""
from pprint import pprint
import airflow_python_sdk
from airflow_python_sdk.api import dag_api
configuration = airflow_python_sdk.Configuration(
host="https://<my-integration-airflow-2.0.0>/api/v1",
username="<very-good-username>",
password="<very-secure-password>"
)
with airflow_python_sdk.ApiClient(configuration) as api_client:
api_instance = dag_api.DAGApi(api_client)
api_resp = api_instance.get_dags(limit=100, offset=0)
pprint(api_resp.dags)