dataqueue

Dataqueue synchronization data source.

This loader ingests the central *_dataqueue.csv log produced by the rig and returns a stream describing every message with absolute and relative timing. It is commonly used to align per-device clocks (treadmill, cameras, nidaq) by extracting anchor pairs for downstream timeline fitting.

class mesofield.datakit.sources.behavior.dataqueue.DataqueueSource

Bases: TimeseriesSource

Load the dataqueue CSV as a time-indexed table.

build_timeseries(path, *, context=None)

Read *_dataqueue.csv and return a time-indexed table.

Parameters:

• path (Path)

• context (LoadContext | None)

Return type:

tuple[ndarray, DataFrame, dict]