airflow.providers.amazon.aws.sensors.step_function

StepFunctionExecutionSensor

轮询 Step Function 状态机执行直到其达到终止状态;如果任务失败则失败。

模块内容

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

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

轮询 Step Function 状态机执行直到其达到终止状态;如果任务失败则失败。

执行成功完成后,Sensor 会将状态机的输出通过 XCom Push 到 output

另请参阅

有关如何使用此 Sensor 的更多信息,请参阅指南:等待 AWS Step Functions 状态机执行状态

参数:
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]

在此类派生时覆盖。

此条目有帮助吗?