merging develop

Author: Cavalcante Damascena

aws_lambda_powertools/logging/__init__.py

@@ -1,5 +1,6 @@
 """Logging utility
 """
+
 from .logger import Logger
 
 __all__ = ["Logger"]

aws_lambda_powertools/logging/logger.py

@@ -345,8 +345,7 @@ def inject_lambda_context(
         log_event: Optional[bool] = None,
         correlation_id_path: Optional[str] = None,
         clear_state: Optional[bool] = False,
-    ) -> AnyCallableT:
-        ...
+    ) -> AnyCallableT: ...
 
     @overload
     def inject_lambda_context(
@@ -355,8 +354,7 @@ def inject_lambda_context(
         log_event: Optional[bool] = None,
         correlation_id_path: Optional[str] = None,
         clear_state: Optional[bool] = False,
-    ) -> Callable[[AnyCallableT], AnyCallableT]:
-        ...
+    ) -> Callable[[AnyCallableT], AnyCallableT]: ...
 
     def inject_lambda_context(
         self,

aws_lambda_powertools/metrics/__init__.py

@@ -1,5 +1,6 @@
 """CloudWatch Embedded Metric Format utility
 """
+
 from aws_lambda_powertools.metrics.base import MetricResolution, MetricUnit, single_metric
 from aws_lambda_powertools.metrics.exceptions import (
     MetricResolutionError,

aws_lambda_powertools/middleware_factory/__init__.py

@@ -1,4 +1,5 @@
 """ Utilities to enhance middlewares """
+
 from .factory import lambda_handler_decorator
 
 __all__ = ["lambda_handler_decorator"]

aws_lambda_powertools/shared/functions.py

@@ -57,18 +57,15 @@ def resolve_max_age(env: str, choice: Optional[int]) -> int:
 
 
 @overload
-def resolve_env_var_choice(env: Optional[str], choice: float) -> float:
-    ...
+def resolve_env_var_choice(env: Optional[str], choice: float) -> float: ...
 
 
 @overload
-def resolve_env_var_choice(env: Optional[str], choice: str) -> str:
-    ...
+def resolve_env_var_choice(env: Optional[str], choice: str) -> str: ...
 
 
 @overload
-def resolve_env_var_choice(env: Optional[str], choice: Optional[str]) -> str:
-    ...
+def resolve_env_var_choice(env: Optional[str], choice: Optional[str]) -> str: ...
 
 
 def resolve_env_var_choice(

aws_lambda_powertools/tracing/__init__.py

@@ -1,7 +1,6 @@
 """Tracing utility
 """
 
-
 from .extensions import aiohttp_trace_config
 from .tracer import Tracer
 

aws_lambda_powertools/tracing/tracer.py

@@ -345,17 +345,15 @@ def decorate(event, context, **kwargs):
 
     # see #465
     @overload
-    def capture_method(self, method: "AnyCallableT") -> "AnyCallableT":
-        ...  # pragma: no cover
+    def capture_method(self, method: "AnyCallableT") -> "AnyCallableT": ...  # pragma: no cover
 
     @overload
     def capture_method(
         self,
         method: None = None,
         capture_response: Optional[bool] = None,
         capture_error: Optional[bool] = None,
-    ) -> Callable[["AnyCallableT"], "AnyCallableT"]:
-        ...  # pragma: no cover
+    ) -> Callable[["AnyCallableT"], "AnyCallableT"]: ...  # pragma: no cover
 
     def capture_method(
         self,

aws_lambda_powertools/utilities/batch/base.py

@@ -339,12 +339,15 @@ def _collect_dynamodb_failures(self):
         return failures
 
     @overload
-    def _to_batch_type(self, record: dict, event_type: EventType, model: "BatchTypeModels") -> "BatchTypeModels":
-        ...  # pragma: no cover
+    def _to_batch_type(
+        self,
+        record: dict,
+        event_type: EventType,
+        model: "BatchTypeModels",
+    ) -> "BatchTypeModels": ...  # pragma: no cover
 
     @overload
-    def _to_batch_type(self, record: dict, event_type: EventType) -> EventSourceDataClassTypes:
-        ...  # pragma: no cover
+    def _to_batch_type(self, record: dict, event_type: EventType) -> EventSourceDataClassTypes: ...  # pragma: no cover
 
     def _to_batch_type(self, record: dict, event_type: EventType, model: Optional["BatchTypeModels"] = None):
         if model is not None:

aws_lambda_powertools/utilities/batch/exceptions.py

@@ -1,6 +1,7 @@
 """
 Batch processing exceptions
 """
+
 from __future__ import annotations
 
 import traceback

aws_lambda_powertools/utilities/data_classes/common.py

@@ -193,7 +193,7 @@ def get_multi_value_query_string_values(
         self,
         name: str,
         default_values: Optional[List[str]] = None,
-    ) ->List[str]:
+    ) -> List[str]:
         """Get multi-value query string parameter values by name
 
         Parameters

aws_lambda_powertools/utilities/data_masking/base.py

@@ -85,20 +85,16 @@ def decrypt(
         )
 
     @overload
-    def erase(self, data, fields: None) -> str:
-        ...
+    def erase(self, data, fields: None) -> str: ...
 
     @overload
-    def erase(self, data: list, fields: list[str]) -> list[str]:
-        ...
+    def erase(self, data: list, fields: list[str]) -> list[str]: ...
 
     @overload
-    def erase(self, data: tuple, fields: list[str]) -> tuple[str]:
-        ...
+    def erase(self, data: tuple, fields: list[str]) -> tuple[str]: ...
 
     @overload
-    def erase(self, data: dict, fields: list[str]) -> dict:
-        ...
+    def erase(self, data: dict, fields: list[str]) -> dict: ...
 
     def erase(self, data: Sequence | Mapping, fields: list[str] | None = None) -> str | list[str] | tuple[str] | dict:
         return self._apply_action(data=data, fields=fields, action=self.provider.erase)

aws_lambda_powertools/utilities/data_masking/provider/kms/aws_encryption_sdk.py

@@ -105,7 +105,6 @@ def decrypt(self, data: str, provider_options: dict | None = None, **encryption_
 
 
 class KMSKeyProvider:
-
     """
     The KMSKeyProvider is responsible for assembling an AWS Key Management Service (KMS)
     client, a caching mechanism, and a keyring for secure key management and data encryption.

aws_lambda_powertools/utilities/idempotency/exceptions.py

@@ -2,7 +2,6 @@
 Idempotency errors
 """
 
-
 from typing import Optional, Union
 
 from aws_lambda_powertools.utilities.idempotency.persistence.datarecord import DataRecord

aws_lambda_powertools/utilities/idempotency/idempotency.py

@@ -1,6 +1,7 @@
 """
 Primary interface for idempotent Lambda functions utility
 """
+
 import functools
 import logging
 import os

aws_lambda_powertools/utilities/idempotency/serialization/base.py

@@ -1,6 +1,7 @@
 """
 Serialization for supporting idempotency
 """
+
 from abc import ABC, abstractmethod
 from typing import Any, Dict
 

aws_lambda_powertools/utilities/parameters/appconfig.py

@@ -2,7 +2,6 @@
 AWS App Config configuration retrieval and caching utility
 """
 
-
 import os
 from typing import TYPE_CHECKING, Any, Dict, Optional, Union
 

aws_lambda_powertools/utilities/parameters/base.py

@@ -1,6 +1,7 @@
 """
 Base for Parameter providers
 """
+
 from __future__ import annotations
 
 import base64
@@ -372,8 +373,7 @@ def transform_value(
     transform: TransformOptions,
     raise_on_transform_error: bool = False,
     key: str = "",
-) -> Dict[str, Any]:
-    ...
+) -> Dict[str, Any]: ...
 
 
 @overload
@@ -382,8 +382,7 @@ def transform_value(
     transform: TransformOptions,
     raise_on_transform_error: bool = False,
     key: str = "",
-) -> Optional[Union[str, bytes, Dict[str, Any]]]:
-    ...
+) -> Optional[Union[str, bytes, Dict[str, Any]]]: ...
 
 
 def transform_value(

aws_lambda_powertools/utilities/parameters/dynamodb.py

@@ -2,7 +2,6 @@
 Amazon DynamoDB parameter retrieval and caching utility
 """
 
-
 from typing import TYPE_CHECKING, Dict, Optional
 
 import boto3

aws_lambda_powertools/utilities/parameters/secrets.py

@@ -2,7 +2,6 @@
 AWS Secrets Manager parameter retrieval and caching utility
 """
 
-
 import os
 from typing import TYPE_CHECKING, Any, Dict, Optional, Union
 

aws_lambda_powertools/utilities/parameters/ssm.py

@@ -1,6 +1,7 @@
 """
 AWS SSM Parameter retrieval and caching utility
 """
+
 from __future__ import annotations
 
 import os
@@ -553,8 +554,7 @@ def get_parameter(
     force_fetch: bool = False,
     max_age: Optional[int] = None,
     **sdk_options,
-) -> str:
-    ...
+) -> str: ...
 
 
 @overload
@@ -565,8 +565,7 @@ def get_parameter(
     force_fetch: bool = False,
     max_age: Optional[int] = None,
     **sdk_options,
-) -> dict:
-    ...
+) -> dict: ...
 
 
 @overload
@@ -577,8 +576,7 @@ def get_parameter(
     force_fetch: bool = False,
     max_age: Optional[int] = None,
     **sdk_options,
-) -> Union[str, dict, bytes]:
-    ...
+) -> Union[str, dict, bytes]: ...
 
 
 @overload
@@ -589,8 +587,7 @@ def get_parameter(
     force_fetch: bool = False,
     max_age: Optional[int] = None,
     **sdk_options,
-) -> bytes:
-    ...
+) -> bytes: ...
 
 
 def get_parameter(
@@ -683,8 +680,7 @@ def get_parameters(
     max_age: Optional[int] = None,
     raise_on_transform_error: bool = False,
     **sdk_options,
-) -> Dict[str, str]:
-    ...
+) -> Dict[str, str]: ...
 
 
 @overload
@@ -697,8 +693,7 @@ def get_parameters(
     max_age: Optional[int] = None,
     raise_on_transform_error: bool = False,
     **sdk_options,
-) -> Dict[str, dict]:
-    ...
+) -> Dict[str, dict]: ...
 
 
 @overload
@@ -711,8 +706,7 @@ def get_parameters(
     max_age: Optional[int] = None,
     raise_on_transform_error: bool = False,
     **sdk_options,
-) -> Dict[str, bytes]:
-    ...
+) -> Dict[str, bytes]: ...
 
 
 @overload
@@ -725,8 +719,7 @@ def get_parameters(
     max_age: Optional[int] = None,
     raise_on_transform_error: bool = False,
     **sdk_options,
-) -> Union[Dict[str, bytes], Dict[str, dict], Dict[str, str]]:
-    ...
+) -> Union[Dict[str, bytes], Dict[str, dict], Dict[str, str]]: ...
 
 
 def get_parameters(
@@ -825,8 +818,7 @@ def get_parameters_by_name(
     decrypt: Optional[bool] = None,
     max_age: Optional[int] = None,
     raise_on_error: bool = True,
-) -> Dict[str, str]:
-    ...
+) -> Dict[str, str]: ...
 
 
 @overload
@@ -836,8 +828,7 @@ def get_parameters_by_name(
     decrypt: Optional[bool] = None,
     max_age: Optional[int] = None,
     raise_on_error: bool = True,
-) -> Dict[str, bytes]:
-    ...
+) -> Dict[str, bytes]: ...
 
 
 @overload
@@ -847,8 +838,7 @@ def get_parameters_by_name(
     decrypt: Optional[bool] = None,
     max_age: Optional[int] = None,
     raise_on_error: bool = True,
-) -> Dict[str, Dict[str, Any]]:
-    ...
+) -> Dict[str, Dict[str, Any]]: ...
 
 
 @overload
@@ -858,8 +848,7 @@ def get_parameters_by_name(
     decrypt: Optional[bool] = None,
     max_age: Optional[int] = None,
     raise_on_error: bool = True,
-) -> Union[Dict[str, str], Dict[str, dict]]:
-    ...
+) -> Union[Dict[str, str], Dict[str, dict]]: ...
 
 
 def get_parameters_by_name(

aws_lambda_powertools/utilities/parser/__init__.py

@@ -1,5 +1,6 @@
 """Advanced event_parser utility
 """
+
 from . import envelopes
 from .envelopes import BaseEnvelope
 from .parser import event_parser, parse

aws_lambda_powertools/utilities/parser/parser.py

@@ -104,13 +104,11 @@ def handler(event: Order, context: LambdaContext):
 
 
 @overload
-def parse(event: Dict[str, Any], model: Type[Model]) -> Model:
-    ...  # pragma: no cover
+def parse(event: Dict[str, Any], model: Type[Model]) -> Model: ...  # pragma: no cover
 
 
 @overload
-def parse(event: Dict[str, Any], model: Type[Model], envelope: Type[Envelope]) -> Model:
-    ...  # pragma: no cover
+def parse(event: Dict[str, Any], model: Type[Model], envelope: Type[Envelope]) -> Model: ...  # pragma: no cover
 
 
 def parse(event: Dict[str, Any], model: Type[Model], envelope: Optional[Type[Envelope]] = None):

aws_lambda_powertools/utilities/serialization.py

@@ -1,4 +1,5 @@
 """Standalone functions to serialize/deserialize common data structures"""
+
 import base64
 import json
 from typing import Any, Callable