straxen.plugins.online_peak_monitor package

Submodules

straxen.plugins.online_peak_monitor.online_peak_monitor module

class straxen.plugins.online_peak_monitor.online_peak_monitor.OnlinePeakMonitor

Bases: Plugin

Plugin to write data to the online-monitor. Data that is written by this plugin should be small such as to not overload the runs- database.

This plugin takes ‘peak_basics’ and ‘lone_hits’. Although they are not strictly related, they are aggregated into a single data_type in order to minimize the number of documents in the online monitor.

Produces ‘online_peak_monitor’ with info on the lone-hits and peaks

area_vs_width_bounds

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

area_vs_width_cut_string

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

area_vs_width_nbins

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

area_width_hist(data)

Make area vs width 2D-hist.

compute(peaks, lone_hits, start, end)

config: Dict

data_kind: str | immutabledict | dict = 'online_peak_monitor'

depends_on: tuple = ('peak_basics', 'lone_hits')

deps: Dict

dtype: tuple | dtype | immutabledict | dict

infer_dtype()

Return dtype of computed data; used only if no dtype attribute defined.

input_buffer: Dict[str, Chunk]

lone_hits_area_bounds

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

lone_hits_cut_string

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

lone_hits_min_gap

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

n_tpc_pmts

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

online_peak_monitor_nbins

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

online_se_bounds

Dispatch on URL protocol.

unrecognized protocol returns identity inspired by dasks Dispatch and fsspec fs protocols.

provides: tuple = ('online_peak_monitor',)

run_i: int

run_id: str

takes_config = immutabledict({'area_vs_width_nbins': <straxen.url_config.URLConfig object>, 'area_vs_width_bounds': <straxen.url_config.URLConfig object>, 'area_vs_width_cut_string': <straxen.url_config.URLConfig object>, 'lone_hits_area_bounds': <straxen.url_config.URLConfig object>, 'online_peak_monitor_nbins': <straxen.url_config.URLConfig object>, 'lone_hits_cut_string': <straxen.url_config.URLConfig object>, 'lone_hits_min_gap': <straxen.url_config.URLConfig object>, 'n_tpc_pmts': <straxen.url_config.URLConfig object>, 'online_se_bounds': <straxen.url_config.URLConfig object>})

Module contents