def merge_record_values()

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


def merge_record_values(metric_key, grouped_rows):
    if 'AnomalyScore' in metric_key:
        return sum(float(key[5]) for key in grouped_rows)
    else:
        return sum(int(key[5]) for key in grouped_rows)