airflow.providers.amazon.aws.sensors.ecs

Module Contents

Classes

EcsBaseSensor

Contains general sensor behavior for Elastic Container Service.

EcsClusterStateSensor

Poll the cluster state until it reaches a terminal state; raises AirflowException with the failure reason.

EcsTaskDefinitionStateSensor

Poll task definition until it reaches a terminal state; raise AirflowException with the failure reason.

EcsTaskStateSensor

Poll the task state until it reaches a terminal state; raises AirflowException with the failure reason.

class airflow.providers.amazon.aws.sensors.ecs.EcsBaseSensor(*, aws_conn_id='aws_default', region_name=None, verify=None, botocore_config=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.ecs.EcsHook]

Contains general sensor behavior for Elastic Container Service.

aws_hook_class[source]
client()[source]

Create and return an EcsHook client.

class airflow.providers.amazon.aws.sensors.ecs.EcsClusterStateSensor(*, cluster_name, target_state=EcsClusterStates.ACTIVE, failure_states=None, **kwargs)[source]

Bases: EcsBaseSensor

Poll the cluster state until it reaches a terminal state; raises AirflowException with the failure reason.

See also

For more information on how to use this operator, take a look at the guide: AWS ECS Cluster State Sensor

Parameters
template_fields: Sequence[str][source]
poke(context)[source]

Override when deriving this class.

class airflow.providers.amazon.aws.sensors.ecs.EcsTaskDefinitionStateSensor(*, task_definition, target_state=EcsTaskDefinitionStates.ACTIVE, **kwargs)[source]

Bases: EcsBaseSensor

Poll task definition until it reaches a terminal state; raise AirflowException with the failure reason.

See also

For more information on how to use this operator, take a look at the guide: AWS ECS Task Definition State Sensor

Parameters
  • task_definition (str) – The family for the latest ACTIVE revision, family and revision (family:revision ) for a specific revision in the family, or full Amazon Resource Name (ARN) of the task definition.

  • target_state (airflow.providers.amazon.aws.hooks.ecs.EcsTaskDefinitionStates | None) – Success state to watch for. (Default: “ACTIVE”)

template_fields: Sequence[str][source]
poke(context)[source]

Override when deriving this class.

class airflow.providers.amazon.aws.sensors.ecs.EcsTaskStateSensor(*, cluster, task, target_state=EcsTaskStates.RUNNING, failure_states=None, **kwargs)[source]

Bases: EcsBaseSensor

Poll the task state until it reaches a terminal state; raises AirflowException with the failure reason.

See also

For more information on how to use this operator, take a look at the guide: AWS ECS Task State Sensor

Parameters
template_fields: Sequence[str][source]
poke(context)[source]

Override when deriving this class.

Was this entry helpful?