@@ -1034,7 +1034,9 @@ def make(self, key):
10341034 sorting_file , base_folder = output_dir
10351035 )
10361036 if si_sorting_ .unit_ids .size == 0 :
1037- logger .info (f"No units found in { sorting_file } . Skipping Unit ingestion..." )
1037+ logger .info (
1038+ f"No units found in { sorting_file } . Skipping Unit ingestion..."
1039+ )
10381040 self .insert1 (key )
10391041 return
10401042
@@ -1247,7 +1249,9 @@ def make(self, key):
12471249
12481250 self .insert1 (key )
12491251 if not len (CuratedClustering .Unit & key ):
1250- logger .info (f"No CuratedClustering.Unit found for { key } , skipping Waveform ingestion." )
1252+ logger .info (
1253+ f"No CuratedClustering.Unit found for { key } , skipping Waveform ingestion."
1254+ )
12511255 return
12521256
12531257 # Get channel and electrode-site mapping
@@ -1303,6 +1307,7 @@ def yield_unit_waveforms():
13031307 ]
13041308
13051309 yield unit_peak_waveform , unit_electrode_waveforms
1310+
13061311 else : # read from kilosort outputs (ecephys pipeline)
13071312 kilosort_dataset = kilosort .Kilosort (output_dir )
13081313
@@ -1510,7 +1515,9 @@ def make(self, key):
15101515
15111516 self .insert1 (key )
15121517 if not len (CuratedClustering .Unit & key ):
1513- logger .info (f"No CuratedClustering.Unit found for { key } , skipping QualityMetrics ingestion." )
1518+ logger .info (
1519+ f"No CuratedClustering.Unit found for { key } , skipping QualityMetrics ingestion."
1520+ )
15141521 return
15151522
15161523 si_sorting_analyzer_dir = output_dir / sorter_name / "sorting_analyzer"
0 commit comments