def merge_record_values()

in source/update_ddb_from_stream/update_ddb_from_stream.py [0:0]

• 7 lines of code
• 4 McCabe index (conditional complexity)

def merge_record_values(metric_key, grouped_rows):
    if 'DeviceTempAnomalyScore' in metric_key:
        return max(float(key[5]) for key in grouped_rows)
    else:
        metric_key_split = metric_key.split('|')
        metric_key_value = metric_key_split[1]
        return type_operator_map[metric_key_value]([float(key[5]) for key in grouped_rows])