Scheduler¶

class dias.Scheduler(config)¶

Bases: object

dias Scheduler.

Puts tasks in a queue and runs them one by one when told. Also calls finish method of tasks.

Methods

`finish_tasks`(self)	Finish all tasks.
`next_task`(self)	Get the next scheduled task.
`start`(self[, pidfile])	Start the scheduler main loop.

Construct the dias scheduler.

Parameters:	config (dict) – dias configuration. Expected to contain the log_level and prometheus_client_port.

Methods

`finish_tasks`(self)	Finish all tasks.
`next_task`(self)	Get the next scheduled task.
`start`(self[, pidfile])	Start the scheduler main loop.

Methods Summary

`finish_tasks`(self)	Finish all tasks.
`next_task`(self)	Get the next scheduled task.
`start`(self[, pidfile])	Start the scheduler main loop.

Methods Documentation

finish_tasks(self)¶

Finish all tasks.

Calls the finish method of the analyzers of each task.

next_task(self)¶

Get the next scheduled task.

Returns:	`Task` – The next task in the queue.

start(self, pidfile=None)¶

Start the scheduler main loop.

This is the entry point for the scheduler main loop.

Parameters:	pidfile (None) – TODO: Not implemented.