airflow.providers.amazon.aws.sensors.eks

Tracking the state of EKS Clusters and Nodegroups.

Module Contents

airflow.providers.amazon.aws.sensors.eks.DEFAULT_CONN_ID = aws_default[source]
class airflow.providers.amazon.aws.sensors.eks.EKSClusterStateSensor(*, cluster_name: str, target_state: ClusterStates = ClusterStates.ACTIVE, aws_conn_id: str = DEFAULT_CONN_ID, region: Optional[str] = None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Check the state of an Amazon EKS Cluster until the state of the Cluster equals the target state.

Parameters

  • cluster_name (str) -- The name of the Cluster to watch. (templated)

  • target_state (ClusterStates) -- Target state of the Cluster. (templated)

  • region (str) -- Which AWS region the connection should use. (templated) If this is None or empty then the default boto3 behaviour is used.

  • aws_conn_id (str) -- The Airflow connection used for AWS credentials. (templated) 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).

template_fields = ['cluster_name', 'target_state', 'aws_conn_id', 'region'][source]
ui_color = #ff9900[source]
ui_fgcolor = #232F3E[source]
poke(self, context)[source]
class airflow.providers.amazon.aws.sensors.eks.EKSNodegroupStateSensor(*, cluster_name: str, nodegroup_name: str, target_state: NodegroupStates = NodegroupStates.ACTIVE, aws_conn_id: str = DEFAULT_CONN_ID, region: Optional[str] = None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Check the state of an Amazon EKS Nodegroup until the state of the Nodegroup equals the target state.

Parameters

  • cluster_name (str) -- The name of the Cluster which the Nodegroup is attached to. (templated)

  • nodegroup_name (str) -- The name of the Nodegroup to watch. (templated)

  • target_state (NodegroupStates) -- Target state of the Nodegroup. (templated)

  • region (str) -- Which AWS region the connection should use. (templated) If this is None or empty then the default boto3 behaviour is used.

  • aws_conn_id (str) -- The Airflow connection used for AWS credentials. (templated) 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).

template_fields = ['cluster_name', 'nodegroup_name', 'target_state', 'aws_conn_id', 'region'][source]
ui_color = #ff9900[source]
ui_fgcolor = #232F3E[source]
poke(self, context)[source]

Was this entry helpful?