File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed
tests/unit/data_classes/required_dependencies Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -73,6 +73,8 @@ def test_dynamodb_stream_trigger_with_tumbling_window_event():
7373 assert dynamodb .stream_view_type == StreamViewType .NEW_AND_OLD_IMAGES
7474
7575 assert parsed_event .window .raw_event == raw_event ["window" ]
76+ assert parsed_event .window .start == raw_event ["window" ]["start" ]
77+ assert parsed_event .window .end == raw_event ["window" ]["end" ]
7678 assert parsed_event .state == raw_event ["state" ]
7779 assert parsed_event .shard_id == raw_event ["shardId" ]
7880 assert parsed_event .event_source_arn == raw_event ["eventSourceARN" ]
Original file line number Diff line number Diff line change @@ -96,6 +96,8 @@ def test_kinesis_stream_with_tumbling_window_event():
9696 assert kinesis .data_as_text () == "Hello, this is a test."
9797
9898 assert parsed_event .window .raw_event == raw_event ["window" ]
99+ assert parsed_event .window .start == raw_event ["window" ]["start" ]
100+ assert parsed_event .window .end == raw_event ["window" ]["end" ]
99101 assert parsed_event .state == raw_event ["state" ]
100102 assert parsed_event .shard_id == raw_event ["shardId" ]
101103 assert parsed_event .event_source_arn == raw_event ["eventSourceARN" ]
You can’t perform that action at this time.
0 commit comments