straxen.plugins.events_mv package

Submodules

straxen.plugins.events_mv.events_mv module

class straxen.plugins.events_mv.events_mv.muVETOEvents[source]

Bases: nVETOEvents

Plugin which computes the boundaries of veto events.

child_plugin = True
compressor = 'zstd'
compute(hitlets_mv, start, end)[source]
config: Dict
data_kind: str | immutabledict | dict = 'events_mv'
depends_on: tuple = 'hitlets_mv'
deps: Dict
dtype: tuple | dtype | immutabledict | dict
event_left_extension_mv

Dispatch on URL protocol.

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

event_min_hits_mv

Dispatch on URL protocol.

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

event_resolving_time_mv

Dispatch on URL protocol.

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

events_seen = 0
get_window_size()[source]

Return the required window size in nanoseconds.

infer_dtype()[source]

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

input_buffer: Dict[str, Chunk]
provides: tuple = ('events_mv',)
run_i: int
run_id: str
takes_config = immutabledict({'event_left_extension_nv': <straxen.url_config.URLConfig object>, 'event_resolving_time_nv': <straxen.url_config.URLConfig object>, 'event_min_hits_nv': <straxen.url_config.URLConfig object>, 'channel_map': <straxen.url_config.URLConfig object>, 'event_left_extension_mv': <straxen.url_config.URLConfig object>, 'event_resolving_time_mv': <straxen.url_config.URLConfig object>, 'event_min_hits_mv': <straxen.url_config.URLConfig object>})

straxen.plugins.events_mv.events_sync_mv module

Module contents