Decode fixes (#1073)

* fix time slicing in get_ahead_behind_distance

* fix fetched attribute name in _get_sort_interval_valid_times

* update dtype to np.int32

* ensure unit wavform group integrity

* update changelog

Author: samuelbray32

CHANGELOG.md

@@ -68,6 +68,7 @@ PositionGroup.alter()
     - Default values for classes on `ImportError` #966
     - Add option to upsample data rate in `PositionGroup` #1008
     - Avoid interpolating over large `nan` intervals in position #1033
+    - Minor code calling corrections #1073
 
 - Position
 

src/spyglass/decoding/v1/clusterless.py

@@ -57,6 +57,11 @@ def create_group(
             "nwb_file_name": nwb_file_name,
             "waveform_features_group_name": group_name,
         }
+        if self & group_key:
+            raise ValueError(
+                f"Group {nwb_file_name}: {group_name} already exists",
+                "please delete the group before creating a new one",
+            )
         self.insert1(
             group_key,
             skip_duplicates=True,
@@ -533,7 +538,7 @@ def get_ahead_behind_distance(self, track_graph=None, time_slice=None):
         classifier = self.fetch_model()
         posterior = (
             self.fetch_results()
-            .acausal_posterior(time=time_slice)
+            .acausal_posterior.sel(time=time_slice)
             .squeeze()
             .unstack("state_bins")
             .sum("state")

src/spyglass/spikesorting/v0/spikesorting_recording.py

@@ -366,7 +366,7 @@ def _get_sort_interval_valid_times(self, key):
             & key
         ).fetch1(
             "nwb_file_name",
-            "sort_interval",
+            "sort_interval_name",
             "preproc_params",
             "interval_list_name",
         )

src/spyglass/spikesorting/v0/spikesorting_sorting.py

@@ -213,7 +213,7 @@ def make(self, key: dict):
             detected_spikes = detect_peaks(recording, **sorter_params)
             sorting = si.NumpySorting.from_times_labels(
                 times_list=detected_spikes["sample_index"],
-                labels_list=np.zeros(len(detected_spikes), dtype=np.int),
+                labels_list=np.zeros(len(detected_spikes), dtype=np.int32),
                 sampling_frequency=recording.get_sampling_frequency(),
             )
         else:

src/spyglass/spikesorting/v1/sorting.py

@@ -240,7 +240,7 @@ def make(self, key: dict):
             detected_spikes = detect_peaks(recording, **sorter_params)
             sorting = si.NumpySorting.from_times_labels(
                 times_list=detected_spikes["sample_index"],
-                labels_list=np.zeros(len(detected_spikes), dtype=np.int),
+                labels_list=np.zeros(len(detected_spikes), dtype=np.int32),
                 sampling_frequency=recording.get_sampling_frequency(),
             )
         else: