temporalio.contrib.aws.lambda_worker._run_worker

module documentation
(source)

Undocumented

Variable logger Undocumented
Class _WorkerDeps External dependencies injected for testability.
Function _default_extract_lambda_ctx Extract (request_id, function_arn) from a Lambda context object.
Function _default_load_config Undocumented
Async Function _invocation_handler Handle a single Lambda invocation.
Function _run_worker_internal Core logic with injected dependencies for testability.
logger = (source)

Undocumented

def _default_extract_lambda_ctx(lambda_context: Any) -> tuple[str, str] | None: (source)

Extract (request_id, function_arn) from a Lambda context object.

def _default_load_config(getenv: Callable[[str], str | None]) -> ClientConfigProfile: (source)

Undocumented

async def _invocation_handler(*, lambda_context: Any, config: LambdaWorkerConfig, deps: _WorkerDeps, extract_lambda_ctx: Callable[[Any], tuple[str, str] | None]): (source)

Handle a single Lambda invocation.

def _run_worker_internal(version: WorkerDeploymentVersion, configure: Callable[[LambdaWorkerConfig], None], deps: _WorkerDeps) -> Callable[[Any, Any], None]: (source)

Core logic with injected dependencies for testability.