diff --git a/aws_lambda_powertools/utilities/parser/models/apigw.py b/aws_lambda_powertools/utilities/parser/models/apigw.py index fc7f5b61d3f..74735ef4919 100644 --- a/aws_lambda_powertools/utilities/parser/models/apigw.py +++ b/aws_lambda_powertools/utilities/parser/models/apigw.py @@ -77,6 +77,7 @@ def check_message_id(cls, values): raise ValueError("messageId is available only when the `eventType` is `MESSAGE`") return values + # validator to normalize requestTimeEpoch @validator("requestTimeEpoch", pre=True) def normalize_timestamp(cls, value): date_utc = datetime.fromtimestamp(int(value) / 1000, tz=timezone.utc) diff --git a/aws_lambda_powertools/utilities/parser/models/kafka.py b/aws_lambda_powertools/utilities/parser/models/kafka.py index dba911bf4d1..0f3573008a1 100644 --- a/aws_lambda_powertools/utilities/parser/models/kafka.py +++ b/aws_lambda_powertools/utilities/parser/models/kafka.py @@ -20,7 +20,7 @@ class KafkaRecordModel(BaseModel): headers: List[Dict[str, bytes]] # validators - _decode_key = validator("key", allow_reuse=True)(base64_decode) # type: ignore[type-var] + _decode_key = validator("key", allow_reuse=True)(base64_decode) # type: ignore[type-var, unused-ignore] @validator("value", pre=True, allow_reuse=True) def data_base64_decode(cls, value):