EksBaseSensor

Amazon

Base class to check various EKS states. Subclasses need to implement get_state and get_terminal_states methods.

View on GitHub

Last Updated: Jan. 26, 2023

Access Instructions

Install the Amazon provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

cluster_nameRequiredThe name of the Cluster
target_stateRequiredWill return successfully when that state is reached.
target_state_typeRequiredThe enum containing the states, will be used to convert the target state if it has to be converted from a string
aws_conn_idThe Airflow connection used for AWS credentials. If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then the default boto3 configuration would be used (and must be maintained on each worker node).
regionWhich AWS region the connection should use. If this is None or empty then the default boto3 behaviour is used.

Documentation

Base class to check various EKS states. Subclasses need to implement get_state and get_terminal_states methods.

Was this page helpful?