airflow.providers.amazon.aws.sensors.lambda_function

Module Contents

Classes

LambdaFunctionStateSensor

Asks for the state of the Lambda until it reaches a target state.
class airflow.providers.amazon.aws.sensors.lambda_function.LambdaFunctionStateSensor(*, function_name, qualifier=None, target_states=['Active'], aws_conn_id='aws_default', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Asks for the state of the Lambda until it reaches a target state. If the query fails, the task will fail.

See also

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

Parameters

  • function_name (str) – The name of the AWS Lambda function, version, or alias.

  • qualifier (str | None) – Specify a version or alias to get details about a published version of the function.

  • target_states (list) – The Lambda states desired.

  • aws_conn_id (str) – aws connection to use, defaults to ‘aws_default’

FAILURE_STATES = ('Failed',)[source]
template_fields: Sequence[str] = ('function_name', 'qualifier')[source]
poke(context)[source]

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

hook()[source]

Was this entry helpful?