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():
73
73
assert dynamodb .stream_view_type == StreamViewType .NEW_AND_OLD_IMAGES
74
74
75
75
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" ]
76
78
assert parsed_event .state == raw_event ["state" ]
77
79
assert parsed_event .shard_id == raw_event ["shardId" ]
78
80
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():
96
96
assert kinesis .data_as_text () == "Hello, this is a test."
97
97
98
98
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" ]
99
101
assert parsed_event .state == raw_event ["state" ]
100
102
assert parsed_event .shard_id == raw_event ["shardId" ]
101
103
assert parsed_event .event_source_arn == raw_event ["eventSourceARN" ]
You can’t perform that action at this time.
0 commit comments