Airflow API Client
ActivePublic
Actions

Authored by atsuko on Wed, Sep 16, 2:26 PM.

Project Tags

None

Referenced Files

	F103280084: Airflow API Client
	Wed, Sep 16, 2:26 PM

Subscribers

None

	from airflow_client import client

	# remote client
	# from wmf_airflow_common.sensors.rest_helper import get_api_client
	# host = "..."
	# api_config = client.Configuration(host=host)
	# api_client = get_api_client(api_config)

	# local client
	from wmf_airflow_common.clients.airflow import LocalAirflowApiClientKubernetes
	api_client = LocalAirflowApiClientKubernetes()

	api_instance = client.DAGApi(api_client)
	api_response = api_instance.get_dags()

Event Timeline