Skip to content

Commit cd6c34f

Browse files
committed
improv: fix kinesis envelope test
1 parent c766c10 commit cd6c34f

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

aws_lambda_powertools/utilities/validation/envelopes.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,5 +6,5 @@
66
SNS = "Records[0].Sns.Message | powertools_json(@)"
77
EVENTBRIDGE = "detail"
88
CLOUDWATCH_EVENTS_SCHEDULED = EVENTBRIDGE
9-
KINESIS_DATA_STREAM = "Records[*].kinesis.powertools_base64(data) | powertools_json(@)"
9+
KINESIS_DATA_STREAM = "Records[*].kinesis.powertools_json(powertools_base64(data))"
1010
CLOUDWATCH_LOGS = "awslogs.powertools_base64_gzip(data) | powertools_json(@).logEvents[*]"

tests/functional/validator/test_validator.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,8 +64,8 @@ def test_eventbridge_envelope(schema, eventbridge_event):
6464
validate(event=eventbridge_event, schema=schema, envelope=envelopes.EVENTBRIDGE)
6565

6666

67-
def test_kinesis_data_stream_envelope(schema, kinesis_event):
68-
validate(event=kinesis_event, schema=schema, envelope=envelopes.KINESIS_DATA_STREAM)
67+
def test_kinesis_data_stream_envelope(schema_array, kinesis_event):
68+
validate(event=kinesis_event, schema=schema_array, envelope=envelopes.KINESIS_DATA_STREAM)
6969

7070

7171
def test_cloudwatch_logs_envelope(cloudwatch_logs_schema, cloudwatch_logs_event):

0 commit comments

Comments
 (0)