Skip to content

Commit d565d76

Browse files
committed
fix(parser): kinesis sequence number should be str
1 parent 8de3729 commit d565d76

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

Diff for: aws_lambda_powertools/utilities/parser/models/kinesis.py

+1-2
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
from typing import List, Union
55

66
from pydantic import BaseModel, validator
7-
from pydantic.types import PositiveInt
87

98
from aws_lambda_powertools.utilities.parser.types import Literal, Model
109

@@ -14,7 +13,7 @@
1413
class KinesisDataStreamRecordPayload(BaseModel):
1514
kinesisSchemaVersion: str
1615
partitionKey: str
17-
sequenceNumber: PositiveInt
16+
sequenceNumber: str
1817
data: Union[bytes, Model] # base64 encoded str is parsed into bytes
1918
approximateArrivalTimestamp: float
2019

Diff for: tests/functional/parser/test_kinesis.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ def handle_kinesis_no_envelope(event: KinesisDataStreamModel, _: LambdaContext):
3535
assert kinesis.approximateArrivalTimestamp == 1545084650.987
3636
assert kinesis.kinesisSchemaVersion == "1.0"
3737
assert kinesis.partitionKey == "1"
38-
assert kinesis.sequenceNumber == 49590338271490256608559692538361571095921575989136588898
38+
assert kinesis.sequenceNumber == "49590338271490256608559692538361571095921575989136588898"
3939
assert kinesis.data == b"Hello, this is a test."
4040

4141

0 commit comments

Comments
 (0)