TestAnalyzer

class dias.analyzers.TestAnalyzer(name, write_dir, state_dir)

Bases: dias.analyzer.Analyzer

Test dias analyzer.

This is a trivial dias analyzer used to test the scheduler.

Attributes:

data_size_max

log_level

period

start_time

state_size_max

wait_time

Methods

add_data_metric(self, name[, description, …])	Add a gauge metric.
add_task_metric(self, metric_name[, …])	Add a gauge metric.
delete_callback(self, deleted_files)	Tell the analyzer that files have been deleted after the task has run.
finish(self)	Shut down the analyzer.
from_config(config, \*args, \*\*kwargs)	Create a new instance with values loaded from config.
init_logger(self[, log_level_override])	Set up the logger.
read_config(self, config[, compare_keys, …])	Set all properties in this class from the supplied config.
run(self)	Run the analyzer.
setup(self)	Set up the analyzer.

Construct the analyzer base class.

Parameters:

• name (String) – Task name.
• write_dir (String) – Path to write output data to.
• state_dir (String) – Path to write state data to.

Attributes:

data_size_max

log_level

period

start_time

state_size_max

wait_time

Methods

add_data_metric(self, name[, description, …])	Add a gauge metric.
add_task_metric(self, metric_name[, …])	Add a gauge metric.
delete_callback(self, deleted_files)	Tell the analyzer that files have been deleted after the task has run.
finish(self)	Shut down the analyzer.
from_config(config, \*args, \*\*kwargs)	Create a new instance with values loaded from config.
init_logger(self[, log_level_override])	Set up the logger.
read_config(self, config[, compare_keys, …])	Set all properties in this class from the supplied config.
run(self)	Run the analyzer.
setup(self)	Set up the analyzer.

Attributes Summary

wait_time

Methods Summary

run(self)	Run the analyzer.
setup(self)	Set up the analyzer.

Attributes Documentation

wait_time = None

Methods Documentation

run(self)

Run the analyzer.

Sleeps the configured wait time.

setup(self)

Set up the analyzer.