Merge branch 'bugfix-metadata_export' into experiment-202411

miniscope_io/io.py

@@ -57,7 +57,10 @@ def append(self, data: List[Any]) -> None:
         data : List[Any]
             The data to be appended.
         """
-        data = [int(value) if isinstance(value, np.generic) else value for value in data]
+        data = [
+            float(value) if isinstance(value, (np.integer, np.floating)) else value
+            for value in data
+        ]
         self.buffer.append(data)
         if len(self.buffer) >= self.buffer_size:
             self.flush_buffer()

miniscope_io/stream_daq.py

@@ -710,14 +710,6 @@ def capture(
                 update_ms=self.config.runtime.plot.update_ms,
             )
 
-        if metadata:
-            self._buffered_writer = BufferedCSVWriter(
-                metadata, buffer_size=self.config.runtime.csvwriter.buffer
-            )
-            self._buffered_writer.append(
-                list(StreamBufferHeader.model_fields.keys()) + ["unix_time"]
-            )
-
         try:
             for image, header_list in exact_iter(imagearray.get, None):
                 self._handle_frame(
@@ -797,6 +789,13 @@ def _handle_frame(
                     except Exception as e:
                         self.logger.exception(f"Exception plotting headers: \n{e}")
                 if metadata:
+                    if self._buffered_writer is None:
+                        self._buffered_writer = BufferedCSVWriter(
+                            metadata, buffer_size=self.config.runtime.csvwriter.buffer
+                        )
+                        self._buffered_writer.append(
+                            list(header.model_dump(warnings=False).keys()) + ["unix_time"]
+                        )
                     self.logger.debug("Saving header metadata")
                     try:
                         self._buffered_writer.append(