airflow.providers.amazon.aws.sensors.lambda_function

Module Contents

Classes

LambdaFunctionStateSensor

Poll the deployment state of the AWS Lambda function until it reaches a target state.
class airflow.providers.amazon.aws.sensors.lambda_function.LambdaFunctionStateSensor(*, function_name, qualifier=None, target_states=None, **kwargs)[source]

Bases: airflow.providers.amazon.aws.sensors.base_aws.AwsBaseSensor[airflow.providers.amazon.aws.hooks.lambda_function.LambdaHook]

Poll the deployment state of the AWS Lambda function until it reaches a target state.

Fails if the query fails.

See also

For more information on how to use this sensor, take a look at the guide: Wait on an AWS Lambda function deployment 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 | None) – The Lambda states desired.

  • aws_conn_id – aws connection to use, defaults to ‘aws_default’ If this is None or empty then the default boto3 behaviour is used. If running Airflow in a distributed manner and aws_conn_id is None or empty, then default boto3 configuration would be used (and must be maintained on each worker node).

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

Override when deriving this class.

Was this entry helpful?