straxen.plugins.individual_peak_monitor package

Submodules

straxen.plugins.individual_peak_monitor.individual_peak_monitor module

class straxen.plugins.individual_peak_monitor.individual_peak_monitor.IndividualPeakMonitor[source]

Bases: Plugin

Plugin to write data needed for the online SE monitor to the online- monitor collection in the runs-database. Data that is written by this plugin should be small such as to not overload the runs- database. If the peaks are large, random max_bytes of data are selected from the peaks.

This plugin takes ‘peak_basics’ and ‘peak_positions_mlp’. 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 ‘individual_peak_monitor’ with info on the peaks and their positions.

compute(peaks)[source]
data_kind: Union[str, immutabledict, dict] = 'individual_peak_monitor'
depends_on: Union[str, tuple, list] = ('peak_basics', 'peak_positions_mlp')
infer_dtype()[source]

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

online_max_bytes

Dispatch on URL protocol.

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

provides: Union[str, tuple, list] = ('individual_peak_monitor',)
takes_config = immutabledict({'online_max_bytes': <straxen.config.url_config.URLConfig object>})

Module contents