airflow.providers.amazon.aws.sensors.step_function

Classes

StepFunctionExecutionSensor

Poll the Step Function State Machine Execution until it reaches a terminal state; fails if the task fails.

Module Contents

class airflow.providers.amazon.aws.sensors.step_function.StepFunctionExecutionSensor(*, execution_arn, **kwargs)[source]

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.step_function.StepFunctionHook]

Poll the Step Function State Machine Execution until it reaches a terminal state; fails if the task fails.

On successful completion of the Execution the Sensor will do an XCom Push of the State Machine’s output to output

See also

For more information on how to use this sensor, take a look at the guide: Wait on an AWS Step Functions state machine execution state

Parameters:
INTERMEDIATE_STATES = ('RUNNING',)[source]
FAILURE_STATES = ('FAILED', 'TIMED_OUT', 'ABORTED')[source]
SUCCESS_STATES = ('SUCCEEDED',)[source]
aws_hook_class[source]
template_fields: collections.abc.Sequence[str][source]
ui_color = '#66c3ff'[source]
execution_arn[source]
poke(context)[source]

Override when deriving this class.

Was this entry helpful?