master.watchers package¶

Subpackages¶

master.watchers.result_processors package

Submodules¶

master.watchers.job module¶

class master.watchers.job.JobWatcher(*args, **kwargs)[source]¶

Bases: master.watchers.WatcherBase

collection = 'talus.job'¶

delete(id)[source]¶

insert(id_, obj)[source]¶

stop()[source]¶: Stop the JobWatcher

update(id, mod)[source]¶

master.watchers.result module¶

class master.watchers.result.ResultWatcher(*args, **kwargs)[source]¶

Bases: master.watchers.WatcherBase

collection = 'talus.result'¶

delete(id)[source]¶

insert(id_, obj)[source]¶

update(id, mod)[source]¶

master.watchers.vm module¶

class master.watchers.vm.VMWatcher(*args, **kwargs)[source]¶

Bases: master.watchers.WatcherBase

collection = 'talus.image'¶

delete(id)[source]¶

insert(id_, obj)[source]¶

update(id, mod)[source]¶

Module contents¶

class master.watchers.WatcherBase(parent_log)[source]¶

Bases: object

stop()[source]¶