// Run pipeline
// TODO only load required measurements
for key in meter.sensor_keys:
for node in self.nodes:
node.reset()
self.results[key] = {}
for chunk in meter.store.load(key=key, **load_kwargs):
processed_chunk = self._run_chunk_through_pipeline(chunk, meter_metadata)
self._update_results(processed_chunk.results, key)
After Change
**load_kwargs : key word arguments for store.load() e.g.:
- periods : list of nilmtk.TimeFrame objects
self._reset()
meter_metadata = deepcopy(meter.metadata)
meter_metadata.update({"device": meter.device})
self._check_requirements(meter_metadata)
