airflow.providers.amazon.aws.sensors.cloud_formation

This module contains sensors for AWS CloudFormation.

Module Contents

Classes

CloudFormationCreateStackSensor

Waits for a stack to be created successfully on AWS CloudFormation.

CloudFormationDeleteStackSensor

Waits for a stack to be deleted successfully on AWS CloudFormation.
class airflow.providers.amazon.aws.sensors.cloud_formation.CloudFormationCreateStackSensor(*, stack_name, aws_conn_id='aws_default', region_name=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a stack to be created successfully on AWS CloudFormation.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an AWS CloudFormation stack creation state

Parameters

  • stack_name – The name of the stack to wait for (templated)

  • aws_conn_id – ID of the Airflow connection where credentials and extra configuration are stored

  • poke_interval – Time in seconds that the job should wait between each try

template_fields :Sequence[str] = ['stack_name'][source]
ui_color = #C5CAE9[source]
poke(self, context)[source]

Function that the sensors defined while deriving this class should override.

hook(self)[source]

Create and return a CloudFormationHook

class airflow.providers.amazon.aws.sensors.cloud_formation.CloudFormationDeleteStackSensor(*, stack_name, aws_conn_id='aws_default', region_name=None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a stack to be deleted successfully on AWS CloudFormation.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an AWS CloudFormation stack deletion state

Parameters

  • stack_name (str) – The name of the stack to wait for (templated)

  • aws_conn_id (str) – ID of the Airflow connection where credentials and extra configuration are stored

  • poke_interval – Time in seconds that the job should wait between each try

template_fields :Sequence[str] = ['stack_name'][source]
ui_color = #C5CAE9[source]
poke(self, context)[source]

Function that the sensors defined while deriving this class should override.

hook(self)[source]

Create and return a CloudFormationHook

Was this entry helpful?