ibllib.pipes.local_server

Functions

job_creator

Server function that will look for creation flags and for each: 1) create the sessions on Alyx 2) register the corresponding raw data files on Alyx 3) create the tasks to be run on Alyx :param root_path: main path containing sessions or session path :param one :param dry :param rerun :param max_md5_size :return:

job_runner

Function to be used as a process to run the jobs as they are created on the database THis will query waiting jobs from the specified Lab :param subjects_path: on servers: /mnt/s0/Data/Subjects.

report_health

Get a few indicators and label the json field of the corresponding lab with them

tasks_runner

Function to run a list of tasks (task dictionary from Alyx query) on a local server :param subjects_path: :param tasks_dict: :param one: :param dry: :param count: maximum number of tasks to run :param time_out: between each task, if time elapsed is greater than time out, returns (seconds) :param kwargs: :return: list of dataset dictionaries

report_health(one)[source]

Get a few indicators and label the json field of the corresponding lab with them

job_creator(root_path, one=None, dry=False, rerun=False, max_md5_size=None)[source]

Server function that will look for creation flags and for each: 1) create the sessions on Alyx 2) register the corresponding raw data files on Alyx 3) create the tasks to be run on Alyx :param root_path: main path containing sessions or session path :param one :param dry :param rerun :param max_md5_size :return:

job_runner(subjects_path, lab=None, dry=False, one=None, count=5)[source]

Function to be used as a process to run the jobs as they are created on the database THis will query waiting jobs from the specified Lab :param subjects_path: on servers: /mnt/s0/Data/Subjects. Contains sessions :param lab: lab name as per Alyx :param dry: :param count: :return:

tasks_runner(subjects_path, tasks_dict, one=None, dry=False, count=5, time_out=None, **kwargs)[source]

Function to run a list of tasks (task dictionary from Alyx query) on a local server :param subjects_path: :param tasks_dict: :param one: :param dry: :param count: maximum number of tasks to run :param time_out: between each task, if time elapsed is greater than time out, returns (seconds) :param kwargs: :return: list of dataset dictionaries