def aggregate()

in scripts/latency.py [0:0]

• 18 lines of code
• 1 McCabe index (conditional complexity)

def aggregate(parsed_log_files, aggregated_log_file):
	assert len(parsed_log_files) > 1

	with open(parsed_log_files[0], 'r') as f:
		aggregate_orders = eval(f.read())

	for parsed_log_file in parsed_log_files[1:]:
		with open(parsed_log_file, 'r') as f:
			data = eval(f.read())
			for (orders_type, orders) in data.items():
				assert len(orders.items()) == 1
				(z_value, items) = list(orders.items())[0]
				assert len(items) == 1
				if z_value in aggregate_orders[orders_type]:
					aggregate_orders[orders_type][z_value] += items
				else:
					aggregate_orders[orders_type][z_value] = items

	with open(aggregated_log_file, 'w') as f:
		f.write(str(aggregate_orders))
		print('aggregated %d log files' % len(parsed_log_files))