@@ -187,10 +187,13 @@ def replace_in_index_level(mi, level, *repls):
187
187
index = df .index if extra_data is None else None ,
188
188
)
189
189
chunk_sizer .log_df (trace_label , "sh_util" , None ) # hand off to caller
190
+ if sharrow_enabled != "test" :
191
+ # if not testing sharrow, we are done with this object now.
192
+ del sh_util
190
193
191
194
timelogger .mark ("sharrow flow" , True , logger , trace_label )
192
195
else :
193
- sh_util , sh_flow = None , None
196
+ sh_util , sh_flow , sh_tree = None , None , None
194
197
timelogger .mark ("sharrow flow" , False )
195
198
196
199
if (
@@ -404,9 +407,9 @@ def to_series(x):
404
407
if sh_flow is not None and trace_rows is not None and trace_rows .any ():
405
408
assert type (trace_rows ) == np .ndarray
406
409
sh_utility_fat = sh_flow .load_dataarray (
407
- # sh_flow.tree .replace_datasets(
408
- # df=df.iloc[trace_rows],
409
- # ),
410
+ sh_tree .replace_datasets (
411
+ df = df .iloc [trace_rows ],
412
+ ),
410
413
dtype = np .float32 ,
411
414
)
412
415
sh_utility_fat = sh_utility_fat [trace_rows , :]
0 commit comments