ruff format

Author: cboulay

src/pycbsdk/cbhw/device/nsp.py

@@ -346,9 +346,13 @@ def _register_basic_callbacks(self):
 
         self.register_config_callback(CBPacketType.CHANREPAINP, self._handle_chaninfo)
         self.register_config_callback(CBPacketType.CHANREPSPKTHR, self._handle_chaninfo)
-        self.register_config_callback(CBPacketType.CHANREPNTRODEGROUP, self._handle_chaninfo)
+        self.register_config_callback(
+            CBPacketType.CHANREPNTRODEGROUP, self._handle_chaninfo
+        )
         self.register_config_callback(CBPacketType.CHANREPDISP, self._handle_chaninfo)
-        self.register_config_callback(CBPacketType.CHANREPUNITOVERRIDES, self._handle_chaninfo)
+        self.register_config_callback(
+            CBPacketType.CHANREPUNITOVERRIDES, self._handle_chaninfo
+        )
 
         self.register_config_callback(CBPacketType.GROUPREP, self._handle_groupinfo)
         self.register_config_callback(CBPacketType.PROCREP, self._handle_procinfo)
@@ -400,7 +404,9 @@ def _handle_sysrep(self, pkt):
     def _handle_chaninfo(self, pkt):
         # If this config packet is limited in scope then it might have some garbage data in its out-of-scope payload.
         # We should update our config, but only the parts that this REP packet is scoped to.
-        if (pkt.header.instrument != self._config["instrument"]) or (pkt.chan > self._config["proc_chans"]):
+        if (pkt.header.instrument != self._config["instrument"]) or (
+            pkt.chan > self._config["proc_chans"]
+        ):
             # Drop channels that do not belong to this instrument
             pass
         elif pkt.header.type in [CBPacketType.CHANREP]:
@@ -446,7 +452,10 @@ def _handle_chaninfo(self, pkt):
             elif pkt.header.type == CBPacketType.CHANREPLABEL:
                 self._config["channel_infos"][pkt.chan].label = pkt.label
                 self._config["channel_infos"][pkt.chan].userflags = pkt.userflags
-            elif pkt.header.type in [CBPacketType.CHANSETSPKTHR, CBPacketType.CHANREPSPKTHR]:
+            elif pkt.header.type in [
+                CBPacketType.CHANSETSPKTHR,
+                CBPacketType.CHANREPSPKTHR,
+            ]:
                 self._config["channel_infos"][pkt.chan].spkthrlevel = pkt.spkthrlevel
             elif pkt.header.type == CBPacketType.CHANREPNTRODEGROUP:
                 # TODO: from use pkt.spkgroup
@@ -502,7 +511,7 @@ def _handle_procmon(self, pkt):
             f";\tcounter - {pkt.counter if has_counter else 'N/A'}"
             f";\tdelta - {pkt_delta}"
             f";\tsent - {pkt.sentpkts}"
-            f";\trate (pkt/samp) - {pkt_delta/update_interval}"
+            f";\trate (pkt/samp) - {pkt_delta / update_interval}"
         )
         self._monitor_state = {
             "counter": pkt.counter if has_counter else -1,

src/pycbsdk/cbhw/packet/packets.py

@@ -530,7 +530,7 @@ def sizes(self) -> list[int]:
         # Convert coords from uint16 to half as many uint32
         # TODO: Use numpy from buffer
         return struct.unpack(
-            f"<{len(self.coords)//2}L",
+            f"<{len(self.coords) // 2}L",
             struct.pack(f"<{len(self.coords)}H", self._array),
         )
 
@@ -540,7 +540,7 @@ def sizes(self, insizes: list[int]):
         assert n_elems <= (self.max_elements // 2)
         # TODO: Use numpy buffer
         self.coords = struct.unpack(
-            f"<{len(insizes)*2}H", struct.pack(f"<{len(insizes)}L", insizes)
+            f"<{len(insizes) * 2}H", struct.pack(f"<{len(insizes)}L", insizes)
         )
 
     @property

src/pycbsdk/examples/group_sample_intervals.py

@@ -23,7 +23,7 @@ def __init__(self, nchans: int, duration=21.0, t_step=1 / 30_000):
 
     def handle_frame(self, pkt):
         if self._write_index < self._buffer.shape[0]:
-            self._buffer[self._write_index, :] = memoryview(pkt.data[:self._nchans])
+            self._buffer[self._write_index, :] = memoryview(pkt.data[: self._nchans])
             self._ts[self._write_index] = pkt.header.time
             self._write_index += 1
 
@@ -35,7 +35,7 @@ def finish(self):
             s_elapsed = ts_elapsed * self._t_step
             n_samps = np.sum(b_ts)
             print(
-                f"Collected {n_samps} samples in {s_elapsed} s\t({n_samps/s_elapsed:.2f} Hz)."
+                f"Collected {n_samps} samples in {s_elapsed} s\t({n_samps / s_elapsed:.2f} Hz)."
             )