fix: iceroxy2

examples/example_data_collection_vx300s.py

@@ -28,7 +28,7 @@ def main(args):
 
     if record:
         nc.create_dataset(
-            name="My Example Dataset",
+            name="Test ice roxy-2",
             description="This is an example dataset",
         )
         print("Created Dataset...")

neuracore-dictionary.txt

@@ -6,6 +6,7 @@ addfinalizer
 addinivalue
 agentview
 agilex
+iceoryx
 aiolimiter
 aiortc
 allclose
@@ -16,6 +17,7 @@ attns
 autocast
 Autoencoders
 autoregressively
+uninit
 autoset
 autouse
 avgpool

neuracore/core/streaming/data_stream.py

@@ -150,11 +150,11 @@ def stop_recording(
             if producer_channel.trace_id:
                 producer_channel.cleanup_producer_channel(
                     stop_cutoff_sequence_number=stop_cutoff_sequence_number,
-                    wait_for_slot_drain=wait_for_producer_drain,
+                    wait_for_transport_drain=wait_for_producer_drain,
                 )
         finally:
             producer_channel.stop_producer_channel(
-                wait_for_slot_drain=wait_for_producer_drain,
+                wait_for_transport_drain=wait_for_producer_drain,
             )
 
     def is_recording(self) -> bool:

neuracore/data_daemon/communications_management/consumer/bridge_chunk_spool.py

@@ -1,4 +1,4 @@
-"""Disk-backed chunk spool for shared-slot completion work."""
+"""Disk-backed chunk spool for video-frame completion work."""
 
 from __future__ import annotations
 
@@ -43,7 +43,7 @@ def __init__(
         )
 
     def append(self, chunk: bytes | bytearray | memoryview) -> ChunkSpoolRef:
-        """Copy one chunk from shared memory into the spool and return its ref."""
+        """Copy one video chunk into the spool and return its ref."""
         chunk_view = chunk if isinstance(chunk, memoryview) else memoryview(chunk)
         chunk_len = len(chunk_view)
 

neuracore/data_daemon/communications_management/consumer/completion_worker.py

@@ -226,7 +226,7 @@ def _release_partial_refs(self, partial: SpoolPartialMessage) -> None:
 
 
 class CompletionWorker:
-    """Non-blocking sharded completion pipeline for shared-slot ingest."""
+    """Non-blocking sharded completion pipeline for video-frame ingest."""
 
     def __init__(
         self,