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

report_health

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

task_queue

Query waiting jobs from the specified Lab

tasks_runner

Function to run a list of tasks (task dictionary from Alyx query) on a local server

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

Parameters

root_path – main path containing sessions or session path

:param one :param dry :param rerun :param max_md5_size :return:

task_queue(mode='all', lab=None, one=None)[source]

Query waiting jobs from the specified Lab

Parameters
  • mode – Whether to return all waiting tasks, or only small or large (specified in LARGE_TASKS) jobs

  • lab – lab name as per Alyx, otherwise try to infer from local globus install

  • one – ONE instance


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

Parameters
  • subjects_path

  • tasks_dict

  • one

  • dry

  • count – maximum number of tasks to run

  • time_out – between each task, if time elapsed is greater than time out, returns (seconds)

  • kwargs

Returns

list of dataset dictionaries