in src/cloudwatch/modules/flusher.py [0:0]
def _expand_value_list(self, value_list):
if len(value_list.values) == 1:
return [value_list]
expanded = []
for ds_name, value in zip(self._resolve_ds_names(value_list), value_list.values):
new_value = value_list.__class__(
host=value_list.host,
plugin=value_list.plugin,
plugin_instance=value_list.plugin_instance,
type=value_list.type,
type_instance=value_list.type_instance + '.{}'.format(ds_name) if value_list.type_instance else ds_name,
time=value_list.time,
interval=value_list.interval,
meta=value_list.meta,
values=[value]
)
expanded.append(new_value)
return expanded