Skip to content
Snippets Groups Projects
Commit 2d1dc33c authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

added close_all_open_series

parent df48845a
No related branches found
No related tags found
No related merge requests found
......@@ -21,7 +21,7 @@ def find_pyx(*path) -> tp.List[str]:
#
setup(name='tempsdb',
version='0.2_a3',
version='0.2_a4',
packages=['tempsdb'],
install_requires=['satella>=2.14.21', 'ujson'],
ext_modules=build([Multibuild('tempsdb', find_pyx('tempsdb')), ],
......
......@@ -16,6 +16,7 @@ cdef class Database:
int page_size=*)
cpdef list get_open_series(self)
cpdef list get_all_series(self)
cpdef int close_all_open_series(self) except -1
cpdef Database create_database(str path)
......@@ -75,6 +75,19 @@ cdef class Database:
result.register_memory_pressure_manager(self.mpm)
return result
cpdef int close_all_open_series(self) except -1:
"""
Closes all open series
.. versionadded:: 0.2
"""
cdef TimeSeries series
with self.lock:
for series in self.open_series.values():
series.close()
self.open_series = {}
return 0
cpdef list get_all_series(self):
"""
Stream all series available within this database
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment