mirror of
https://github.com/balkian/tsih.git
synced 2025-09-17 18:42:23 +00:00
Compare commits
2 Commits
92c5c219bd
...
0.1.9
Author | SHA1 | Date | |
---|---|---|---|
|
eaddd89e8c | ||
|
4e0e95fbe7 |
@@ -10,7 +10,7 @@ import tempfile
|
||||
|
||||
logger = logging.getLogger(__name__)
|
||||
|
||||
__version__ = '0.1.6'
|
||||
__version__ = '0.1.9'
|
||||
|
||||
from collections import UserDict, namedtuple
|
||||
|
||||
@@ -138,7 +138,7 @@ class History:
|
||||
self._close()
|
||||
|
||||
def _close(self):
|
||||
if self._db is None:
|
||||
if not hasattr(self, '_db') or self._db is None:
|
||||
return
|
||||
self.flush_cache()
|
||||
self._db.close()
|
||||
@@ -400,9 +400,9 @@ class Records():
|
||||
return sum(1 for i in self._filter if i is not None) == 3
|
||||
|
||||
def __iter__(self):
|
||||
for column, series in self._df.iteritems():
|
||||
for column, series in self._df.items():
|
||||
key, dict_id = column
|
||||
for t_step, value in series.iteritems():
|
||||
for t_step, value in series.items():
|
||||
r = Record(t_step=t_step,
|
||||
dict_id=dict_id,
|
||||
key=key,
|
||||
@@ -414,7 +414,7 @@ class Records():
|
||||
f = self._filter
|
||||
try:
|
||||
i = self._df[f.key][str(f.dict_id)]
|
||||
ix = i.index.get_loc(f.t_step, method='ffill')
|
||||
ix = i.index.get_indexer([f.t_step], method='ffill')[0]
|
||||
return i.iloc[ix]
|
||||
except KeyError as ex:
|
||||
return self.dtypes[f.key][2]()
|
||||
|
Reference in New Issue
Block a user