airflow.providers.amazon.aws.sensors.step_function_execution

Module Contents

class airflow.providers.amazon.aws.sensors.step_function_execution.StepFunctionExecutionSensor(*, execution_arn: str, aws_conn_id: str = 'aws_default', region_name: Optional[str] = None, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Asks for the state of the Step Function State Machine Execution until it reaches a failure state or success state. If it fails, failing the task.

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

Parameters

  • execution_arn (str) -- execution_arn to check the state of

  • aws_conn_id (str) -- aws connection to use, defaults to 'aws_default'

INTERMEDIATE_STATES = ['RUNNING'][source]
FAILURE_STATES = ['FAILED', 'TIMED_OUT', 'ABORTED'][source]
SUCCESS_STATES = ['SUCCEEDED'][source]
template_fields = ['execution_arn'][source]
template_ext = [][source]
ui_color = #66c3ff[source]
poke(self, context)[source]
get_hook(self)[source]

Create and return a StepFunctionHook

Was this entry helpful?