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

Attributes

CONFIG_GROUP_NAME

INVALID_CREDENTIALS_EXCEPTIONS

CommandType

ExecutorConfigType

Classes

LambdaQueuedTask

Represents a Lambda task that is queued. The task 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 task that is queued. The task will be run in the next heartbeat.

key: airflow.models.taskinstancekey.TaskInstanceKey[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_run_task_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]
airflow.providers.amazon.aws.executors.aws_lambda.utils.CommandType[source]
airflow.providers.amazon.aws.executors.aws_lambda.utils.ExecutorConfigType[source]

Was this entry helpful?