higgs_dna.workflows package

Subpackages

Submodules

higgs_dna.workflows.base module

class higgs_dna.workflows.base.HggBaseProcessor(metaconditions: Dict[str, Any], systematics: Dict[str, List[str]] | None, corrections: Dict[str, List[str]] | None, apply_trigger: bool, output_location: str | None, taggers: List[Any] | None, trigger_group: str, analysis: str, skipCQR: bool, skipJetVetoMap: bool, year: Dict[str, List[str]] | None, doDeco: bool, output_format: str)[source]

Bases: ProcessorABC

add_diphoton_mva(diphotons: Array, events: Array) Array[source]
add_photonid_mva(photons: Array, events: Array) Array[source]
apply_filters_and_triggers(events: Array) Array[source]
postprocess(accumulant: Dict[Any, Any]) Any[source]

Final processing on aggregated accumulator

Do any final processing on the resulting accumulator object, it should be modified in-place

process(events: Array) Dict[Any, Any][source]

Processes a single NanoEvents chunk

Returns a filled accumulator object

process_extra(events: Array) Array[source]

higgs_dna.workflows.dystudies module

class higgs_dna.workflows.dystudies.DYStudiesProcessor(metaconditions: Dict[str, Any], systematics: Dict[str, List[Any]] = None, corrections: Dict[str, List[Any]] = None, apply_trigger: bool = False, output_location: str | None = None, taggers: List[Any] | None = None, skipCQR: bool = False, skipJetVetoMap: bool = False, year: Dict[str, List[str]] = None, doDeco: bool = False, output_format: str = 'parquet')[source]

Bases: HggBaseProcessor

postprocess(accumulant: Dict[Any, Any]) Any[source]

Final processing on aggregated accumulator

Do any final processing on the resulting accumulator object, it should be modified in-place

process_extra(events: Array) Array[source]
class higgs_dna.workflows.dystudies.TagAndProbeProcessor(metaconditions: Dict[str, Any], systematics: Dict[str, List[Any]] = None, corrections: Dict[str, List[str]] | None = None, apply_trigger: bool = False, output_location: str | None = None, taggers: List[Any] | None = None, skipCQR: bool = False, skipJetVetoMap: bool = False, year: Dict[str, List[str]] | None = None, doDeco: bool = False, output_format: str = 'parquet')[source]

Bases: HggBaseProcessor

postprocess(accumulant: Dict[Any, Any]) Any[source]

Final processing on aggregated accumulator

Do any final processing on the resulting accumulator object, it should be modified in-place

process(events: Array) Dict[Any, Any][source]

Processes a single NanoEvents chunk

Returns a filled accumulator object

process_extra(events: Array) Array[source]

Module contents

class higgs_dna.workflows.DYStudiesProcessor(metaconditions: Dict[str, Any], systematics: Dict[str, List[Any]] = None, corrections: Dict[str, List[Any]] = None, apply_trigger: bool = False, output_location: str | None = None, taggers: List[Any] | None = None, skipCQR: bool = False, skipJetVetoMap: bool = False, year: Dict[str, List[str]] = None, doDeco: bool = False, output_format: str = 'parquet')[source]

Bases: HggBaseProcessor

postprocess(accumulant: Dict[Any, Any]) Any[source]

Final processing on aggregated accumulator

Do any final processing on the resulting accumulator object, it should be modified in-place

process_extra(events: Array) Array[source]