def METHOD_NAME():
    # GIVEN a KinesisDataStreamModel is instantiated with CloudWatch Logs compressed data
    raw_event = load_event("kinesisStreamCloudWatchLogsEvent.json")
    stream_data = KinesisDataStreamModel(**raw_event)
    single_record = stream_data.Records[0]
    # WHEN we try to extract CloudWatch Logs from KinesisDataStreamRecordPayload model
    extracted_logs = extract_cloudwatch_logs_from_event(stream_data)
    individual_logs = [extract_cloudwatch_logs_from_record(record) for record in stream_data.Records]
    single_log = extract_cloudwatch_logs_from_record(single_record)
    # THEN we should have extracted any potential logs as CloudWatchLogsDecode models
    assert len(extracted_logs) == len(individual_logs)
    assert isinstance(single_log, CloudWatchLogsDecode)