ibllib.pipes.video_tasks

Classes

VideoCompress	Task to compress raw video data from .avi to .mp4 format.
VideoConvert	Task that converts compressed avi to mp4 format and renames video and camlog files.
VideoRegisterRaw	Task to register raw video data.
VideoSyncQcBpod	Task to sync camera timestamps to main DAQ timestamps N.B Signatures only reflect new daq naming convention, non compatible with ephys when not running on server
VideoSyncQcCamlog	Task to sync camera timestamps to main DAQ timestamps when camlog files are used.
VideoSyncQcNidq	Task to sync camera timestamps to main DAQ timestamps N.B Signatures only reflect new daq naming convention, non compatible with ephys when not running on server

class VideoRegisterRaw(session_path, cameras, **kwargs)

Bases: VideoTask, RegisterRawDataTask

Task to register raw video data. Builds up list of files to register from list of cameras given in session params file

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 VideoCompress(session_path, cameras, **kwargs)

Bases: VideoTask

Task to compress raw video data from .avi to .mp4 format.

priority = 90

job_size = 'large'

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 VideoConvert(session_path, cameras, **kwargs)

Bases: VideoTask

Task that converts compressed avi to mp4 format and renames video and camlog files. Specific to UCLA widefield implementation

priority = 90

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 VideoSyncQcCamlog(session_path, cameras, **kwargs)

Bases: VideoTask

Task to sync camera timestamps to main DAQ timestamps when camlog files are used. Specific to UCLA widefield implementation

priority = 40

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 VideoSyncQcBpod(session_path, cameras, **kwargs)

Bases: VideoTask

Task to sync camera timestamps to main DAQ timestamps N.B Signatures only reflect new daq naming convention, non compatible with ephys when not running on server

priority = 40

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 VideoSyncQcNidq(session_path, cameras, **kwargs)

Bases: VideoTask

Task to sync camera timestamps to main DAQ timestamps N.B Signatures only reflect new daq naming convention, non compatible with ephys when not running on server

priority = 40

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)