Skip to content

Commit eb4bef7

Browse files
Update aws_lambda_powertools/utilities/data_classes/kinesis_stream_event.py
Co-authored-by: Leandro Damascena <[email protected]> Signed-off-by: kiitosu <[email protected]>
1 parent 44589bb commit eb4bef7

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

aws_lambda_powertools/utilities/data_classes/kinesis_stream_event.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,11 @@ def records(self) -> Iterator[KinesisStreamRecord]:
128128

129129
@property
130130
def window(self) -> KinesisStreamWindow | None:
131-
return KinesisStreamWindow(self["window"])
131+
window = self.get("window")
132+
if window:
133+
return KinesisStreamWindow(window)
134+
135+
return window
132136

133137
@property
134138
def state(self) -> dict[str, Any]:

0 commit comments

Comments
 (0)