spine.ana.manager

Manages the operation of analysis scripts.

Classes

AnaManager(cfg[, log_dir, prefix])

Manager class to initialize and execute analysis scripts.

class spine.ana.manager.AnaManager(cfg: Mapping[str, Any], log_dir: str | None = None, prefix: str | None = None)

Manager class to initialize and execute analysis scripts.

Analysis scripts use the output of the reconstruction chain and the post-processors and produce simple CSV files.

It loads all the analysis scripts and feeds them data. It initializes CSV writers needed to store the output of the analysis scripts.

Methods

__call__(data)	Pass one batch of data through the managed modules.
close()	Close all analysis script writers and flush remaining data.
flush()	Flush all analysis script writer buffers.
parse_config(log_dir, prefix[, overwrite, ...])	Parse the analysis tool configuration.

parse_config(log_dir: str | None, prefix: str | None, overwrite: bool | None = None, prefix_output: bool = False, buffer_size: int = 1, **modules: dict[str, Any] | None) → None

Parse the analysis tool configuration.

Parameters:

• log_dir (str) – Output CSV file directory (shared with driver log)

• prefix (str) – Input file prefix. If requested, it will be used to prefix all the output CSV files.

• overwrite (bool, optional) – If True, overwrite the CSV logs if they already exist

• prefix_output (bool, optional) – If True, will prefix the output CSV names with the input file name

• buffer_size (int, default 1) – CSV file buffer size. 1 is line buffered (default), -1 uses system default, 0 is unbuffered, >1 is buffer size in bytes

• **modules (dict) – List of analysis script modules

close() → None

Close all analysis script writers and flush remaining data.

This should be called when analysis is complete to ensure all CSV files are properly closed and data is written.

flush() → None

Flush all analysis script writer buffers.

This forces any buffered data to be written to disk without closing the files.