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)