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

Attributes Summary

wait_time

Methods Summary

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

Attributes Documentation

wait_time = None

Methods Documentation

run()

Run the analyzer.

Sleeps the configured wait time.

setup()

Set up the analyzer.