airflow.providers.amazon.aws.sensors.ec2

Module Contents

Classes

EC2InstanceStateSensor

Poll the state of the AWS EC2 instance until the instance reaches the target state.
class airflow.providers.amazon.aws.sensors.ec2.EC2InstanceStateSensor(*, target_state, instance_id, aws_conn_id='aws_default', region_name=None, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Poll the state of the AWS EC2 instance until the instance reaches the target state.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an Amazon EC2 instance state

Parameters

  • target_state (str) – target state of instance

  • instance_id (str) – id of the AWS EC2 instance

  • region_name (str | None) – (optional) aws region name associated with the client

  • deferrable (bool) – if True, the sensor will run in deferrable mode

template_fields: Sequence[str] = ('target_state', 'instance_id', 'region_name')[source]
ui_color = '#cc8811'[source]
ui_fgcolor = '#ffffff'[source]
valid_states = ['running', 'stopped', 'terminated'][source]
execute(context)[source]

This is the main method to derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

hook()[source]
poke(context)[source]

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

execute_complete(context, event=None)[source]

Was this entry helpful?