diff --git a/src/spikeinterface/sorters/internal/lupin.py b/src/spikeinterface/sorters/internal/lupin.py index 7865114f6e..e09036fd8c 100644 --- a/src/spikeinterface/sorters/internal/lupin.py +++ b/src/spikeinterface/sorters/internal/lupin.py @@ -194,7 +194,8 @@ def _run_from_folder(cls, sorter_output_folder, params, verbose): if apply_cmr: recording = common_reference(recording) else: - recording = apply_preprocessing_pipeline(recording, params["preprocessing_dict"]) + recording = apply_preprocessing_pipeline(recording_raw, params["preprocessing_dict"]) + recording = recording.astype("float32") recording = whiten( recording, diff --git a/src/spikeinterface/sorters/internal/tridesclous2.py b/src/spikeinterface/sorters/internal/tridesclous2.py index 67fcb2e599..a4306dd431 100644 --- a/src/spikeinterface/sorters/internal/tridesclous2.py +++ b/src/spikeinterface/sorters/internal/tridesclous2.py @@ -159,7 +159,8 @@ def _run_from_folder(cls, sorter_output_folder, params, verbose): if apply_cmr: recording = common_reference(recording) else: - recording = apply_preprocessing_pipeline(recording, params["preprocessing_dict"]) + recording = apply_preprocessing_pipeline(recording_raw, params["preprocessing_dict"]) + recording = recording.astype("float32") if params["apply_motion_correction"]: interpolate_motion_kwargs = dict( diff --git a/src/spikeinterface/sortingcomponents/tools.py b/src/spikeinterface/sortingcomponents/tools.py index 70afc17b39..3efb4e6d2e 100644 --- a/src/spikeinterface/sortingcomponents/tools.py +++ b/src/spikeinterface/sortingcomponents/tools.py @@ -429,11 +429,11 @@ def cache_preprocessing( elif mode == "folder": assert folder is not None, "cache_preprocessing(): folder must be given" - recording = recording.save_to_folder(folder=folder) + recording = recording.save_to_folder(folder=folder, **job_kwargs) cache_info["folder"] = folder elif mode == "zarr": assert folder is not None, "cache_preprocessing(): folder must be given" - recording = recording.save_to_zarr(folder=folder) + recording = recording.save_to_zarr(folder=folder, **job_kwargs) cache_info["folder"] = folder elif mode == "no-cache": recording = recording @@ -445,7 +445,7 @@ def cache_preprocessing( cache_info["mode"] = "memory" elif folder is not None: # then try folder - recording = recording.save_to_folder(folder=folder) + recording = recording.save_to_folder(folder=folder, **job_kwargs) cache_info["mode"] = "folder" cache_info["folder"] = folder else: