airflow.providers.amazon.aws.triggers.eks

Module Contents

Classes

EksCreateFargateProfileTrigger

Asynchronously wait for the fargate profile to be created.

EksDeleteFargateProfileTrigger

Asynchronously wait for the fargate profile to be deleted.

EksCreateNodegroupTrigger

Trigger for EksCreateNodegroupOperator.

EksDeleteNodegroupTrigger

Trigger for EksDeleteNodegroupOperator.
class airflow.providers.amazon.aws.triggers.eks.EksCreateFargateProfileTrigger(cluster_name, fargate_profile_name, waiter_delay, waiter_max_attempts, aws_conn_id, region=None, region_name=None)[source]

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Asynchronously wait for the fargate profile to be created.

Parameters

  • cluster_name (str) – The name of the EKS cluster

  • fargate_profile_name (str) – The name of the fargate profile

  • waiter_delay (int) – The amount of time in seconds to wait between attempts.

  • waiter_max_attempts (int) – The maximum number of attempts to be made.

  • aws_conn_id (str) – The Airflow connection used for AWS credentials.

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.eks.EksDeleteFargateProfileTrigger(cluster_name, fargate_profile_name, waiter_delay, waiter_max_attempts, aws_conn_id, region=None, region_name=None)[source]

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Asynchronously wait for the fargate profile to be deleted.

Parameters

  • cluster_name (str) – The name of the EKS cluster

  • fargate_profile_name (str) – The name of the fargate profile

  • waiter_delay (int) – The amount of time in seconds to wait between attempts.

  • waiter_max_attempts (int) – The maximum number of attempts to be made.

  • aws_conn_id (str) – The Airflow connection used for AWS credentials.

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.eks.EksCreateNodegroupTrigger(cluster_name, nodegroup_name, waiter_delay, waiter_max_attempts, aws_conn_id, region_name)[source]

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger for EksCreateNodegroupOperator.

The trigger will asynchronously poll the boto3 API and wait for the nodegroup to be in the state specified by the waiter.

Parameters

  • waiter_name – Name of the waiter to use, for instance ‘nodegroup_active’ or ‘nodegroup_deleted’

  • cluster_name (str) – The name of the EKS cluster associated with the node group.

  • nodegroup_name (str) – The name of the nodegroup to check.

  • waiter_delay (int) – The amount of time in seconds to wait between attempts.

  • waiter_max_attempts (int) – The maximum number of attempts to be made.

  • aws_conn_id (str) – The Airflow connection used for AWS credentials.

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

hook()[source]

Override in subclasses to return the right hook.

class airflow.providers.amazon.aws.triggers.eks.EksDeleteNodegroupTrigger(cluster_name, nodegroup_name, waiter_delay, waiter_max_attempts, aws_conn_id, region_name)[source]

Bases: airflow.providers.amazon.aws.triggers.base.AwsBaseWaiterTrigger

Trigger for EksDeleteNodegroupOperator.

The trigger will asynchronously poll the boto3 API and wait for the nodegroup to be in the state specified by the waiter.

Parameters

  • waiter_name – Name of the waiter to use, for instance ‘nodegroup_active’ or ‘nodegroup_deleted’

  • cluster_name (str) – The name of the EKS cluster associated with the node group.

  • nodegroup_name (str) – The name of the nodegroup to check.

  • waiter_delay (int) – The amount of time in seconds to wait between attempts.

  • waiter_max_attempts (int) – The maximum number of attempts to be made.

  • aws_conn_id (str) – The Airflow connection used for AWS credentials.

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

hook()[source]

Override in subclasses to return the right hook.

Was this entry helpful?