straxen.plugins.online_monitor_nv package

Submodules

straxen.plugins.online_monitor_nv.online_monitor_nv module

class straxen.plugins.online_monitor_nv.online_monitor_nv.OnlineMonitorNV[source]

Bases: Plugin

Plugin to write data of nVeto detector to the online-monitor. Data that is written by this plugin should be small (~MB/chunk) to not overload the runs-database.

This plugin takes ‘hitlets_nv’ and ‘events_nv’. 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_monitor_nv’ with info on the hitlets_nv and events_nv

channel_map

Dispatch on URL protocol.

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

compute(hitlets_nv, events_nv, start, end)[source]
config: Dict
data_kind: str | immutabledict | dict = 'online_monitor_nv'
depends_on: tuple = ('hitlets_nv', 'events_nv')
deps: Dict
dtype: tuple | dtype | immutabledict | dict
ends_with = '_nv'
events_area_bounds

Dispatch on URL protocol.

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

events_area_nbins

Dispatch on URL protocol.

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

infer_dtype()[source]

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

input_buffer: Dict[str, Chunk]
provides: tuple = ('online_monitor_nv',)
run_i: int
run_id: str
takes_config = immutabledict({'channel_map': <straxen.url_config.URLConfig object>, 'events_area_bounds': <straxen.url_config.URLConfig object>, 'events_area_nbins': <straxen.url_config.URLConfig object>})

Module contents