analyzer.core.running

Classes

Saver

Functions

getUniqueFilename(file_name)

getRepos([extra_dataset_paths, extra_era_paths])

getMatchedCollections(dataset_repo, descs)

getTasks(dataset_repo, era_repo, dataset_descs[, ...])

getTasksExplicit(dataset_repo, era_repo, ...[, ...])

runTasks(analyzer, tasks, executor, output[, ...])

runFromPath(path, output, executor_name[, ...])

patchFromPath(path, existing, output, executor_name[, ...])

Module Contents

analyzer.core.running.getUniqueFilename(file_name)[source]
class analyzer.core.running.Saver(output)[source]
output[source]
__call__(key, result)[source]
analyzer.core.running.getRepos(extra_dataset_paths=None, extra_era_paths=None)[source]
analyzer.core.running.getMatchedCollections(dataset_repo, descs)[source]
analyzer.core.running.getTasks(dataset_repo, era_repo, dataset_descs, location_priorities=None, filter_dataset=None, filter_sample=None)[source]
analyzer.core.running.getTasksExplicit(dataset_repo, era_repo, dataset_descs, samples, location_priorities=None)[source]
analyzer.core.running.runTasks(analyzer, tasks, executor, output, max_sample_events=None)[source]
analyzer.core.running.runFromPath(path, output, executor_name, max_sample_events=None, filter_dataset=None, filter_sample=None, limit_pipelines=None, return_analyzer=False)[source]
analyzer.core.running.patchFromPath(path, existing, output, executor_name, filter_dataset=None, filter_sample=None, limit_pipelines=None)[source]