@@ -98,8 +98,6 @@ def hdf5_to_dataframe(
98
98
search_pattern = "Stream" ,
99
99
)
100
100
101
- test_proc .close ()
102
-
103
101
column_names = [alias_dict .get (group , group ) for group in group_names ]
104
102
105
103
if time_stamps :
@@ -137,6 +135,8 @@ def hdf5_to_dataframe(
137
135
138
136
array_stack = da .concatenate (arrays , axis = 1 ).T
139
137
138
+ test_proc .close ()
139
+
140
140
return ddf .from_dask_array (array_stack , columns = column_names )
141
141
142
142
@@ -188,8 +188,6 @@ def hdf5_to_timed_dataframe(
188
188
search_pattern = "Stream" ,
189
189
)
190
190
191
- test_proc .close ()
192
-
193
191
column_names = [alias_dict .get (group , group ) for group in group_names ]
194
192
195
193
if time_stamps :
@@ -226,6 +224,8 @@ def hdf5_to_timed_dataframe(
226
224
227
225
array_stack = da .concatenate (arrays , axis = 1 ).T
228
226
227
+ test_proc .close ()
228
+
229
229
return ddf .from_dask_array (array_stack , columns = column_names )
230
230
231
231
@@ -720,16 +720,16 @@ def get_start_and_end_time(self) -> Tuple[float, float]:
720
720
Returns:
721
721
Tuple[float, float]: A tuple containing the start and end time stamps
722
722
"""
723
- h5file = load_h5_in_memory ( self .files [0 ])
723
+ h5filename = self .files [0 ]
724
724
timestamps = hdf5_to_array (
725
- h5file ,
725
+ h5filename = h5filename ,
726
726
group_names = self ._config ["dataframe" ]["hdf5_groupnames" ],
727
727
time_stamps = True ,
728
728
)
729
729
ts_from = timestamps [- 1 ][1 ]
730
- h5file = load_h5_in_memory ( self .files [- 1 ])
730
+ h5filename = self .files [- 1 ]
731
731
timestamps = hdf5_to_array (
732
- h5file ,
732
+ h5filename = h5filename ,
733
733
group_names = self ._config ["dataframe" ]["hdf5_groupnames" ],
734
734
time_stamps = True ,
735
735
)
0 commit comments