In [32]: dropout_rate2.run()
KeyError Traceback (most recent call last)
in ()
----> 1 dropout_rate2.run()
/root/nilmtk/nilmtk/node.pyc in run(self)
40 """Pulls data through the pipeline. Useful if we just want to calculate
41 some stats."""
---> 42 for _ in self.process():
43 pass
44
/root/nilmtk/nilmtk/stats/dropoutrate.pyc in process(self)
14 def process(self):
15 self.check_requirements()
---> 16 metadata = self.upstream.get_metadata()
17 sample_period = metadata['device']['sample_period']
18 for chunk in self.upstream.process():
/root/nilmtk/nilmtk/node.pyc in get_metadata(self)
78 # Don't bother to deepcopy upstream's metadata if
79 # we aren't going to modify it.
---> 80 metadata = self.upstream.get_metadata()
81 return metadata
82
/root/nilmtk/nilmtk/node.pyc in get_metadata(self)
73 if self.results:
74 metadata = deepcopy(self.upstream.get_metadata())
---> 75 results_dict = self.results.to_dict()
76 recursively_update_dict(metadata, results_dict)
77 else:
/root/nilmtk/nilmtk/stats/dropoutrateresults.pyc in to_dict(self)
37
38 def to_dict(self):
---> 39 return {'statistics': {'dropout_rate': self.combined()}}
40
41 def plot(self, ax=None):
/root/nilmtk/nilmtk/stats/dropoutrateresults.pyc in combined(self)
22 dropout_rate : float, [0,1]
23 """
---> 24 tot_samples = self._data['n_samples'].sum()
25 proportion = self._data['n_samples'] / tot_samples
26 dropout_rate = (self._data['dropout_rate'] * proportion).sum()
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/frame.pyc in getitem(self, key)
1967 return self._getitem_multilevel(key)
1968 else:
-> 1969 return self._getitem_column(key)
1970
1971 def _getitem_column(self, key):
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/frame.pyc in _getitem_column(self, key)
1974 # get column
1975 if self.columns.is_unique:
-> 1976 return self._get_item_cache(key)
1977
1978 # duplicate columns & possible reduce dimensionality
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/generic.pyc in _get_item_cache(self, item)
1089 res = cache.get(item)
1090 if res is None:
-> 1091 values = self._data.get(item)
1092 res = self._box_item_values(item, values)
1093 cache[item] = res
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/internals.pyc in get(self, item, fastpath)
3209
3210 if not isnull(item):
-> 3211 loc = self.items.get_loc(item)
3212 else:
3213 indexer = np.arange(len(self.items))[isnull(self.items)]
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/index.pyc in get_loc(self, key, method, tolerance)
1757 'backfill or nearest lookups')
1758 key = _values_from_object(key)
-> 1759 return self._engine.get_loc(key)
1760
1761 indexer = self.get_indexer([key], method=method,
pandas/index.pyx in pandas.index.IndexEngine.get_loc (pandas/index.c:3979)()
pandas/index.pyx in pandas.index.IndexEngine.get_loc (pandas/index.c:3843)()
pandas/hashtable.pyx in pandas.hashtable.PyObjectHashTable.get_item (pandas/hashtable.c:12265)()
pandas/hashtable.pyx in pandas.hashtable.PyObjectHashTable.get_item (pandas/hashtable.c:12216)()
KeyError: 'n_samples'
In [32]: dropout_rate2.run()
KeyError Traceback (most recent call last)
in ()
----> 1 dropout_rate2.run()
/root/nilmtk/nilmtk/node.pyc in run(self)
40 """Pulls data through the pipeline. Useful if we just want to calculate
41 some stats."""
---> 42 for _ in self.process():
43 pass
44
/root/nilmtk/nilmtk/stats/dropoutrate.pyc in process(self)
14 def process(self):
15 self.check_requirements()
---> 16 metadata = self.upstream.get_metadata()
17 sample_period = metadata['device']['sample_period']
18 for chunk in self.upstream.process():
/root/nilmtk/nilmtk/node.pyc in get_metadata(self)
78 # Don't bother to deepcopy upstream's metadata if
79 # we aren't going to modify it.
---> 80 metadata = self.upstream.get_metadata()
81 return metadata
82
/root/nilmtk/nilmtk/node.pyc in get_metadata(self)
73 if self.results:
74 metadata = deepcopy(self.upstream.get_metadata())
---> 75 results_dict = self.results.to_dict()
76 recursively_update_dict(metadata, results_dict)
77 else:
/root/nilmtk/nilmtk/stats/dropoutrateresults.pyc in to_dict(self)
37
38 def to_dict(self):
---> 39 return {'statistics': {'dropout_rate': self.combined()}}
40
41 def plot(self, ax=None):
/root/nilmtk/nilmtk/stats/dropoutrateresults.pyc in combined(self)
22 dropout_rate : float, [0,1]
23 """
---> 24 tot_samples = self._data['n_samples'].sum()
25 proportion = self._data['n_samples'] / tot_samples
26 dropout_rate = (self._data['dropout_rate'] * proportion).sum()
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/frame.pyc in getitem(self, key)
1967 return self._getitem_multilevel(key)
1968 else:
-> 1969 return self._getitem_column(key)
1970
1971 def _getitem_column(self, key):
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/frame.pyc in _getitem_column(self, key)
1974 # get column
1975 if self.columns.is_unique:
-> 1976 return self._get_item_cache(key)
1977
1978 # duplicate columns & possible reduce dimensionality
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/generic.pyc in _get_item_cache(self, item)
1089 res = cache.get(item)
1090 if res is None:
-> 1091 values = self._data.get(item)
1092 res = self._box_item_values(item, values)
1093 cache[item] = res
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/internals.pyc in get(self, item, fastpath)
3209
3210 if not isnull(item):
-> 3211 loc = self.items.get_loc(item)
3212 else:
3213 indexer = np.arange(len(self.items))[isnull(self.items)]
/root/anaconda2/envs/nilmtk-env/lib/python2.7/site-packages/pandas/core/index.pyc in get_loc(self, key, method, tolerance)
1757 'backfill or nearest lookups')
1758 key = _values_from_object(key)
-> 1759 return self._engine.get_loc(key)
1760
1761 indexer = self.get_indexer([key], method=method,
pandas/index.pyx in pandas.index.IndexEngine.get_loc (pandas/index.c:3979)()
pandas/index.pyx in pandas.index.IndexEngine.get_loc (pandas/index.c:3843)()
pandas/hashtable.pyx in pandas.hashtable.PyObjectHashTable.get_item (pandas/hashtable.c:12265)()
pandas/hashtable.pyx in pandas.hashtable.PyObjectHashTable.get_item (pandas/hashtable.c:12216)()
KeyError: 'n_samples'