airflow.providers.amazon.aws.executors.aws_lambda.utils

Attributes

CONFIG_GROUP_NAME

INVALID_CREDENTIALS_EXCEPTIONS

CommandType

ExecutorConfigType

Classes

LambdaQueuedTask

Represents a Lambda workload that is queued. The workload will be run in the next heartbeat.

InvokeLambdaKwargsConfigKeys

Config keys loaded which are valid lambda invoke args.

AllLambdaConfigKeys

All config keys which are related to the Lambda Executor.

Module Contents

airflow.providers.amazon.aws.executors.aws_lambda.utils.CONFIG_GROUP_NAME = 'aws_lambda_executor'[source]
airflow.providers.amazon.aws.executors.aws_lambda.utils.INVALID_CREDENTIALS_EXCEPTIONS = ['ExpiredTokenException', 'InvalidClientTokenId', 'UnrecognizedClientException'][source]
class airflow.providers.amazon.aws.executors.aws_lambda.utils.LambdaQueuedTask[source]

Represents a Lambda workload that is queued. The workload will be run in the next heartbeat.

key: airflow.executors.workloads.types.WorkloadKey[source]
command: CommandType[source]
queue: str[source]
executor_config: ExecutorConfigType[source]
attempt_number: int[source]
next_attempt_time: datetime.datetime[source]
class airflow.providers.amazon.aws.executors.aws_lambda.utils.InvokeLambdaKwargsConfigKeys[source]

Bases: airflow.providers.amazon.aws.executors.utils.base_config_keys.BaseConfigKeys

Config keys loaded which are valid lambda invoke args.

FUNCTION_NAME = 'function_name'[source]
QUALIFIER = 'function_qualifier'[source]
class airflow.providers.amazon.aws.executors.aws_lambda.utils.AllLambdaConfigKeys[source]

Bases: InvokeLambdaKwargsConfigKeys

All config keys which are related to the Lambda Executor.

AWS_CONN_ID = 'conn_id'[source]
CHECK_HEALTH_ON_STARTUP = 'check_health_on_startup'[source]
MAX_INVOKE_ATTEMPTS = 'max_invoke_attempts'[source]
REGION_NAME = 'region_name'[source]
QUEUE_URL = 'queue_url'[source]
DLQ_URL = 'dead_letter_queue_url'[source]
END_WAIT_TIMEOUT = 'end_wait_timeout'[source]
type airflow.providers.amazon.aws.executors.aws_lambda.utils.CommandType = Sequence[str] | Sequence[ExecuteTask | ExecuteCallback][source]
airflow.providers.amazon.aws.executors.aws_lambda.utils.ExecutorConfigType[source]

Was this entry helpful?