ibllib.pipes.sync_tasks
Classes
Task to rename, compress and register raw daq data with .bin format collected using NIDAQ |
|
Extract sync pulses from NIDAQ .bin / .cbin file N.B Only extracts sync from sync collection (i.e not equivalent to EphysPulses that extracts sync pulses for each probe) |
|
Task to register raw DAQ data. |
- class SyncRegisterRaw(session_path, **kwargs)[source]
Bases:
RegisterRawDataTask
Task to register raw DAQ data.
Registers DAQ software output for a given device. The object should be _*_DAQdata, where the namespace identifies the DAQ model or acquisition software, e.g. ‘mcc’, ‘ni’ or ‘ni-usb-6211’. At minimum there should be a raw data dataset of the form _*_DAQdata.raw*, e.g. ‘_mc_DAQdata.raw.pqt’. The following are optional attribute datasets: - _*_DAQdata.timestamps.npy: for timeline the timestamps array is separate from the samples. - _*_DAQdata.meta.json: for timeline all acquisition meta data (e.g. sample rate, channel names) are stored in a separate file. - _*_DAQdata.wiring.json: for SpikeGLX the channel map is stored in this file. _timeline_softwareEvents.log.htsv: UDP messages and other software events in DAQ time.
- priority = 100
- job_size = 'small'
- property signature
dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object’s
(key, value) pairs
- dict(iterable) -> new dictionary initialized as if via:
d = {} for k, v in iterable:
d[k] = v
- dict(**kwargs) -> new dictionary initialized with the name=value pairs
in the keyword argument list. For example: dict(one=1, two=2)
- class SyncMtscomp(session_path, **kwargs)[source]
Bases:
DynamicTask
Task to rename, compress and register raw daq data with .bin format collected using NIDAQ
- priority = 90
- cpu = 2
- io_charge = 30
- job_size = 'small'
- property signature
dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object’s
(key, value) pairs
- dict(iterable) -> new dictionary initialized as if via:
d = {} for k, v in iterable:
d[k] = v
- dict(**kwargs) -> new dictionary initialized with the name=value pairs
in the keyword argument list. For example: dict(one=1, two=2)
- class SyncPulses(session_path, **kwargs)[source]
Bases:
DynamicTask
Extract sync pulses from NIDAQ .bin / .cbin file N.B Only extracts sync from sync collection (i.e not equivalent to EphysPulses that extracts sync pulses for each probe)
# TODO generalise to other daq and file formats, generalise to 3A probes
- priority = 90
- cpu = 2
- io_charge = 30
- job_size = 'small'
- property signature
dict() -> new empty dictionary dict(mapping) -> new dictionary initialized from a mapping object’s
(key, value) pairs
- dict(iterable) -> new dictionary initialized as if via:
d = {} for k, v in iterable:
d[k] = v
- dict(**kwargs) -> new dictionary initialized with the name=value pairs
in the keyword argument list. For example: dict(one=1, two=2)