Index

A

a (config_keys.ConfigSizeSpec property), [1] add() (merge_utils.merge_set.MergeSet method) (meta.MergeMetaAll method) (meta.MergeMetaMax method) (meta.MergeMetaMin method) (meta.MergeMetaOverride method) (meta.MergeMetaSubset method) (meta.MergeMetaSum method) (meta.MergeMetaUnion method) (meta.MergeMetaUnique method)

add_origin() (in module meta) add_replica() (replicas.PathFinder method) (replicas.PathListFinder method) (replicas.RucioFinder method) add_rse() (replicas.PathListFinder method) all_files (merge_utils.merge_set.MergeSet property) append() (config_keys.ConfigList method), [1] assign_site() (scheduler.JobScheduler method) at() (merge_utils.merge_set.MergeSet method) auto_output() (in module meta)

B

b (config_keys.ConfigSizeSpec property), [1]

bad (replicas.Status property) BaseRSE (class in replicas)

C

cache_local() (replicas.BaseRSE method) cache_xrootd() (replicas.BaseRSE method) check() (replicas.BaseRSE method) check_cache() (replicas.BaseRSE method) check_condition() (in module config_keys), [1] check_consistency() (merge_utils.merge_set.MergeSet method) check_duplicates() (retriever.DidRetriever method) check_environment() (in module config) check_errors() (merge_utils.merge_set.MergeSet method) check_existence() (retriever.MetaRetriever method) check_local() (replicas.BaseRSE method) check_method() (in module meta) check_namespaces() (retriever.DidRetriever method) check_parents() (retriever.MetaRetriever method) check_replica() (replicas.PathFinder method) check_required() (in module meta) check_xrootd() (replicas.BaseRSE method) CheckConfiguration module checksum() (replicas.RucioFinder method) checksum_local() (replicas.BaseRSE method) checksum_xrootd() (replicas.BaseRSE method) chunk_distances() (scheduler.JobScheduler method) chunk_id (merge_utils.merge_set.MergeChunk property) config module config_keys module, [1]

ConfigBool (class in config_keys), [1] ConfigCollection (class in config_keys), [1] ConfigCondition (class in config_keys), [1] ConfigDict (class in config_keys), [1] ConfigFloat (class in config_keys), [1] ConfigInt (class in config_keys), [1] ConfigKey (class in config_keys), [1] ConfigList (class in config_keys), [1] ConfigMap (class in config_keys), [1] ConfigNum (class in config_keys), [1] ConfigOption (class in config_keys), [1] ConfigPath (class in config_keys), [1] ConfigSet (class in config_keys), [1] ConfigSizeSpec (class in config_keys), [1] ConfigString (class in config_keys), [1] ConfigTuple (class in config_keys), [1] ConfigValue (class in config_keys), [1] connect() (merge_utils.metacat_utils.MetaCatWrapper method) (merge_utils.rucio_utils.RucioWrapper method) (replicas.PathFinder method) (replicas.PathListFinder method) (replicas.RucioFinder method) (retriever.MetaRetriever method) (scheduler.JobScheduler method) (scheduler.JustinScheduler method) (scheduler.LocalScheduler method) critical() (merge_utils.merge_set.MergeFileError class method) custom_serializer() (in module config)

D

did (merge_utils.merge_set.MergeFile property) DidRetriever (class in retriever) disconnect() (merge_utils.metacat_utils.MetaCatWrapper method) (merge_utils.rucio_utils.RucioWrapper method) (replicas.PathFinder method) (retriever.MetaRetriever method) (scheduler.JobScheduler method)

dump() (in module config)

E

end_idx (merge_utils.merge_set.MergeSet property) enum (merge_utils.merge_set.MergeSet property) enum_good (merge_utils.merge_set.MergeSet property)

expand_path() (in module merge_utils.io_utils) extend() (config_keys.ConfigList method), [1] (config_keys.ConfigSet method), [1]

F

file_distances() (scheduler.JobScheduler method) file_format (merge_utils.merge_set.MergeFile property) file_serializer() (in module retriever) files (replicas.PathFinder property) (retriever.MetaRetriever property) (scheduler.JobScheduler property)

files() (merge_utils.metacat_utils.MetaCatWrapper method) find_cfg() (in module merge_utils.io_utils) find_file() (in module merge_utils.io_utils) find_runner() (in module merge_utils.io_utils) first (merge_utils.merge_set.MergeFileError property) fix() (in module meta) format() (config_keys.ConfigString method), [1]

G

GenericRSE (class in replicas) get() (config_keys.ConfigDict method), [1] (config_keys.ConfigMap method), [1] (in module replicas) (in module retriever) get_batch() (retriever.MetaRetriever method) get_by_did() (merge_utils.merge_set.MergeSet method) get_by_idx() (merge_utils.merge_set.MergeSet method) get_cfgs() (in module merge_utils.pass2_fix) get_done() (retriever.MetaRetriever method) get_fields() (merge_utils.merge_set.MergeFile method) get_files() (retriever.MetaRetriever method) get_host() (in module replicas) get_inputs() (in module merge_utils.__main__) get_key() (in module config) get_metadata() (replicas.PathFinder method) (retriever.DidRetriever method) (retriever.LocalMetaRetriever method) (retriever.MetaRetriever method) (retriever.QueryRetriever method)

get_parser() (in module merge_utils.__main__) get_path() (in module replicas) get_paths() (replicas.PathFinder method) (replicas.PathListFinder method) (replicas.RucioFinder method) get_pfns() (in module merge_utils.pass2_fix) get_port() (in module replicas) get_protocol() (in module replicas) get_replicas() (merge_utils.rucio_utils.RucioWrapper method) get_rse() (merge_utils.rucio_utils.RucioWrapper method) get_rses() (merge_utils.rucio_utils.RucioWrapper method) get_siblings() (retriever.MetaRetriever method) get_site_rse_distances() (in module merge_utils.justin_utils) get_slice() (merge_utils.merge_set.MergeSet method) good (merge_utils.merge_set.MergeFile property) (replicas.Status property) good_files (merge_utils.merge_set.MergeSet property) group (merge_utils.merge_set.MergeFileError property) group_by_count() (merge_utils.merge_set.MergeSet method) group_by_size() (merge_utils.merge_set.MergeSet method) groups() (merge_utils.merge_set.MergeSet method)

H

handling (merge_utils.merge_set.MergeFileError property)

I

input_batches() (replicas.PathFinder method) (retriever.MetaRetriever method) (scheduler.JobScheduler method) InputBatch (class in retriever)

inputs() (merge_utils.merge_set.MergeChunk method) insert() (merge_utils.merge_set.MergeSet method) items() (config_keys.ConfigDict method), [1] (config_keys.ConfigMap method), [1]

J

JobScheduler (class in scheduler)

justin_cmd() (scheduler.JustinScheduler method) JustinScheduler (class in scheduler)

K

keys() (config_keys.ConfigMap method), [1]

L

load() (in module config) LocalMetaRetriever (class in retriever) LocalScheduler (class in scheduler) log_dict() (in module merge_utils.io_utils)

log_list() (in module merge_utils.io_utils) log_method() (in module meta) log_nonzero() (in module merge_utils.io_utils) log_print() (in module merge_utils.io_utils)

M

main() (in module merge_utils.__main__) (in module merge_utils.pass2_fix) make_cfg_key() (in module config_keys), [1] make_child() (merge_utils.merge_set.MergeChunk method) make_name() (merge_utils.merge_set.MergeChunk method) make_names() (in module meta) match_method() (in module meta) merge_cfg_keys() (in module meta) merge_tar() (in module runners.merge_tar) merge_utils.__init__ module merge_utils.__main__ module merge_utils.io_utils module merge_utils.justin_utils module merge_utils.merge_set module merge_utils.metacat_utils module merge_utils.pass2_fix module merge_utils.rucio_utils module MergeChunk (class in merge_utils.merge_set) merged_keys() (in module meta) MergeFile (class in merge_utils.merge_set) MergeFileError (class in merge_utils.merge_set) MergeMetaAll (class in meta) MergeMetaMax (class in meta) MergeMetaMin (class in meta)

MergeMetaOverride (class in meta) MergeMetaSubset (class in meta) MergeMetaSum (class in meta) MergeMetaUnion (class in meta) MergeMetaUnique (class in meta) MergeSet (class in merge_utils.merge_set) meta module MetaCatWrapper (class in merge_utils.metacat_utils) metadata (merge_utils.merge_set.MergeChunk property) MetaRetriever (class in retriever) MetaValidator module MetaValidator() (in module MetaValidator) module CheckConfiguration config config_keys, [1] merge_utils.__init__ merge_utils.__main__ merge_utils.io_utils merge_utils.justin_utils merge_utils.merge_set merge_utils.metacat_utils merge_utils.pass2_fix merge_utils.rucio_utils meta MetaValidator replicas retriever runners.merge_tar scheduler

N

n (config_keys.ConfigSizeSpec property), [1] name (merge_utils.merge_set.MergeFile property)

namespace (merge_utils.merge_set.MergeChunk property) (merge_utils.merge_set.MergeFile property) (retriever.MetaRetriever property)

O

outputs() (merge_utils.merge_set.MergeChunk method)

override() (in module config)

P

parents (merge_utils.merge_set.MergeChunk property) parents() (in module meta) parse_spec() (config_keys.ConfigSizeSpec method), [1] parse_term() (config_keys.ConfigSizeSpec method), [1] parse_type() (in module config_keys), [1] path_to_xrootd() (in module replicas)

PathFinder (class in replicas) PathListFinder (class in replicas) ping() (replicas.BaseRSE method) pkg_dir() (in module merge_utils.io_utils) print_metadata() (in module merge_utils.__main__) print_replicas() (in module merge_utils.__main__) protocol (replicas.Replica property)

Q

query() (merge_utils.metacat_utils.MetaCatWrapper method)

QueryRetriever (class in retriever)

R

read_config_file() (in module merge_utils.io_utils) read_json() (in module merge_utils.io_utils) Replica (class in replicas) replica_checker() (replicas.PathFinder method) replica_distances() (scheduler.JobScheduler method) (scheduler.LocalScheduler method) replicas module resume() (in module config) resume_job() (in module merge_utils.__main__)

retriever module RucioFinder (class in replicas) RucioRSE (class in replicas) RucioWrapper (class in merge_utils.rucio_utils) run() (retriever.MetaRetriever method) (scheduler.JobScheduler method) run_loop() (scheduler.JobScheduler method) runners.merge_tar module

S

s (config_keys.ConfigSizeSpec property), [1] schedule() (scheduler.JobScheduler method) (scheduler.JustinScheduler method) (scheduler.LocalScheduler method) scheduler module set() (config_keys.ConfigValue method), [1] set_cmd_opts() (in module config) set_distance() (replicas.RucioRSE method) set_error() (merge_utils.merge_set.MergeSet method) set_error_handling() (in module config) set_host() (in module config) set_log_level() (in module merge_utils.io_utils) set_method() (in module meta) set_method_auto() (in module meta)

set_method_custom() (in module meta) set_parents() (merge_utils.merge_set.MergeFile method) set_paths() (replicas.PathFinder method) (replicas.PathListFinder method) (replicas.RucioFinder method) set_urls() (replicas.RucioRSE method) settings() (merge_utils.merge_set.MergeChunk method) setup_job_dir() (in module merge_utils.io_utils) setup_log() (in module merge_utils.io_utils) spec() (merge_utils.merge_set.MergeChunk method) specs (merge_utils.merge_set.MergeChunk property) split_files() (scheduler.JobScheduler method) src_dir() (in module merge_utils.io_utils) start_job() (in module merge_utils.__main__) Status (class in replicas) StatusMeta (class in replicas)

T

tier (merge_utils.merge_set.MergeChunk property)

U

update() (config_keys.ConfigMap method), [1] (in module config)

upload_cfg() (scheduler.JustinScheduler method) uuid() (in module config)

V

val() (config_keys.ConfigValue method), [1] valid (meta.MergeMetaAll property) (meta.MergeMetaMax property) (meta.MergeMetaMin property) (meta.MergeMetaOverride property) (meta.MergeMetaSubset property) (meta.MergeMetaSum property) (meta.MergeMetaUnion property) (meta.MergeMetaUnique property)

validate() (in module meta) (merge_utils.merge_set.MergeFile method) value (config_keys.ConfigValue property), [1] (meta.MergeMetaAll property) (meta.MergeMetaUnion property) values() (config_keys.ConfigMap method), [1]

W

warn (meta.MergeMetaSubset property) write_script() (scheduler.JobScheduler method) (scheduler.JustinScheduler method) (scheduler.LocalScheduler method)

write_specs() (scheduler.JobScheduler method)

X

xrdfs() (replicas.BaseRSE method)

xrootd_to_path() (in module replicas)