reco package

Submodules

reco.gen_job module

class reco.gen_job.Parallel(output_file, seed=512, number_of_threads=1, number_of_events=-1, events_per_job=-1, event_numbers=None, merge=False, ntuple_name='particles', overwrite=False, dry_run=False)[source]

Bases: object

Parameters:

  • output_file (str)

  • seed (int)

  • number_of_threads (int)

  • number_of_events (int)

  • events_per_job (int)

  • event_numbers (str | List[int])

  • merge (bool)

  • ntuple_name (str)

  • overwrite (bool)

  • dry_run (bool)

build_plan()[source]
get_events_per_job()[source]
reco.gen_job.merge_args(parser)[source]
reco.gen_job.update_args(args)[source]

reco.reco_job module

class reco.reco_job.Parallel(files, output_file, number_of_threads=1, number_of_events=-1, events_per_job=-1, merge=False, ntuple_name='CollectionTree', overwrite=False, dry_run=False)[source]

Bases: object

Parameters:

  • files (List[str])

  • output_file (str)

  • number_of_threads (int)

  • number_of_events (int)

  • events_per_job (int)

  • merge (bool)

  • ntuple_name (str)

  • overwrite (bool)

  • dry_run (bool)

build_plan()[source]
Return type:

Dict

reco.reco_job.create_parallel_job(args)[source]
reco.reco_job.merge_args(parser, exclude_input_file=False)[source]
Parameters:

exclude_input_file (bool)

reco.reco_job.update_args(args)[source]

Module contents

class reco.Parallel(files, output_file, number_of_threads=1, number_of_events=-1, events_per_job=-1, merge=False, ntuple_name='CollectionTree', overwrite=False, dry_run=False)[source]

Bases: object

Parameters:

  • files (List[str])

  • output_file (str)

  • number_of_threads (int)

  • number_of_events (int)

  • events_per_job (int)

  • merge (bool)

  • ntuple_name (str)

  • overwrite (bool)

  • dry_run (bool)

build_plan()[source]
Return type:

Dict

reco.check_file_exists(path, ntuple_name)[source]
Parameters:

  • path (str)

  • ntuple_name (str)

Return type:

bool

reco.chunks(lst, n)[source]
Parameters:

  • lst (List)

  • n (int)

Return type:

List

reco.create_parallel_job(args)[source]
reco.merge(output_file, files)[source]
Parameters:

  • output_file (str)

  • files (List[str])

reco.merge_args(parser, exclude_input_file=False)[source]
Parameters:

exclude_input_file (bool)

reco.merge_args_from_file(parser)[source]
reco.update_args(args)[source]
reco.update_args_from_file(args)[source]