Commit c4f9988a authored by Romain Courteaud's avatar Romain Courteaud 🐙

promise/plugin: keep the periodicity configurable

parent 56b74390
...@@ -18,7 +18,7 @@ class RunPromise(GenericPromise): ...@@ -18,7 +18,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
# check backup ran OK every 5 minutes # check backup ran OK every 5 minutes
self.setPeriodicity(minute=5) self.setPeriodicity(float(self.getConfig('frequency', 5)))
def sense(self): def sense(self):
""" """
......
...@@ -12,7 +12,7 @@ class RunPromise(GenericPromise): ...@@ -12,7 +12,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log') self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log')
self.stats_period = int(self.getConfig('stats-period')) self.stats_period = int(self.getConfig('stats-period'))
......
...@@ -8,7 +8,7 @@ from slapos.grid.promise import interface ...@@ -8,7 +8,7 @@ from slapos.grid.promise import interface
class RunPromise(JSONPromise): class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log') self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log')
self.stats_period = int(self.getConfig('stats-period')) self.stats_period = int(self.getConfig('stats-period'))
self.min_rxtx_delay_threshold = float(self.getConfig('min-rxtx-delay', 0)) self.min_rxtx_delay_threshold = float(self.getConfig('min-rxtx-delay', 0))
......
...@@ -8,7 +8,7 @@ from slapos.grid.promise import interface ...@@ -8,7 +8,7 @@ from slapos.grid.promise import interface
class RunPromise(JSONPromise): class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.amarisoft_rf_info_log = self.getConfig('amarisoft-rf-info-log') self.amarisoft_rf_info_log = self.getConfig('amarisoft-rf-info-log')
self.sdr_devchan = "/dev/sdr%s@%s" % (self.getConfig('sdr_dev'), self.getConfig('sfp_port')) self.sdr_devchan = "/dev/sdr%s@%s" % (self.getConfig('sdr_dev'), self.getConfig('sfp_port'))
self.stats_period = int(self.getConfig('stats-period')) self.stats_period = int(self.getConfig('stats-period'))
......
...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise): ...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
# set periodicity to run the promise twice per day # set periodicity to run the promise twice per day
self.custom_frequency = int(self.getConfig('frequency', 720)) self.custom_frequency = float(self.getConfig('frequency', 720))
self.setPeriodicity(self.custom_frequency) self.setPeriodicity(self.custom_frequency)
# Skip test check on this promise # Skip test check on this promise
self.setTestLess() self.setTestLess()
......
...@@ -13,7 +13,7 @@ r = re.compile(br"^([0-9]+\-[0-9]+\-[0-9]+ [0-9]+\:[0-9]+\:[0-9]+)(\,[0-9]+) - ( ...@@ -13,7 +13,7 @@ r = re.compile(br"^([0-9]+\-[0-9]+\-[0-9]+ [0-9]+\:[0-9]+\:[0-9]+)(\,[0-9]+) - (
class RunPromise(GenericPromise): class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=10) self.setPeriodicity(float(self.getConfig('frequency', 10)))
def sense(self): def sense(self):
log_file = self.getConfig('log-file') log_file = self.getConfig('log-file')
......
...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise): ...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise):
Sets the configuration and the periodicity. Sets the configuration and the periodicity.
""" """
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
def sense(self): def sense(self):
......
...@@ -7,7 +7,7 @@ from slapos.grid.promise import interface ...@@ -7,7 +7,7 @@ from slapos.grid.promise import interface
class RunPromise(JSONPromise): class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.amarisoft_rf_info_log = self.getConfig('amarisoft-rf-info-log') self.amarisoft_rf_info_log = self.getConfig('amarisoft-rf-info-log')
self.stats_period = int(self.getConfig('stats-period')) self.stats_period = int(self.getConfig('stats-period'))
......
...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise): ...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
# set periodicity to run the promise twice per day # set periodicity to run the promise twice per day
self.custom_frequency = int(self.getConfig('frequency', 720)) self.custom_frequency = float(self.getConfig('frequency', 720))
self.setPeriodicity(self.custom_frequency) self.setPeriodicity(self.custom_frequency)
# Skip test check on this promise # Skip test check on this promise
self.setTestLess() self.setTestLess()
......
...@@ -8,7 +8,7 @@ class RunPromise(GenericPromise): ...@@ -8,7 +8,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=2) self.setPeriodicity(float(self.getConfig('frequency', 2)))
def sense(self): def sense(self):
......
...@@ -14,7 +14,7 @@ from slapos.grid.promise import interface ...@@ -14,7 +14,7 @@ from slapos.grid.promise import interface
class RunPromise(JSONPromise): class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.config_log = self.getConfig('config-log') self.config_log = self.getConfig('config-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -14,7 +14,7 @@ from slapos.grid.promise import interface ...@@ -14,7 +14,7 @@ from slapos.grid.promise import interface
class RunPromise(JSONPromise): class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.stats_log = self.getConfig('stats-log') self.stats_log = self.getConfig('stats-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise): ...@@ -17,7 +17,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.netconf_log = self.getConfig('netconf-log') self.netconf_log = self.getConfig('netconf-log')
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
......
...@@ -9,7 +9,7 @@ class RunPromise(GenericPromise): ...@@ -9,7 +9,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
def sense(self): def sense(self):
""" """
......
...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise): ...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
# set periodicity to run the promise twice per day # set periodicity to run the promise twice per day
self.custom_frequency = int(self.getConfig('frequency', 720)) self.custom_frequency = float(self.getConfig('frequency', 720))
self.setPeriodicity(self.custom_frequency) self.setPeriodicity(self.custom_frequency)
# Skip test check on this promise # Skip test check on this promise
self.setTestLess() self.setTestLess()
......
...@@ -10,7 +10,7 @@ class RunPromise(JSONPromise): ...@@ -10,7 +10,7 @@ class RunPromise(JSONPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
self.testing = self.getConfig('testing') == "True" self.testing = self.getConfig('testing') == "True"
self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log') self.amarisoft_stats_log = self.getConfig('amarisoft-stats-log')
self.stats_period = int(self.getConfig('stats-period')) self.stats_period = int(self.getConfig('stats-period'))
......
...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise): ...@@ -10,7 +10,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=1) self.setPeriodicity(float(self.getConfig('frequency', 1)))
def sense(self): def sense(self):
......
...@@ -12,7 +12,7 @@ ADDRESS_USAGE = ( ...@@ -12,7 +12,7 @@ ADDRESS_USAGE = (
class RunPromise(GenericPromise): class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=2) self.setPeriodicity(float(self.getConfig('frequency', 2)))
self.result_count = int(self.getConfig('result-count', 3)) self.result_count = int(self.getConfig('result-count', 3))
self.failure_amount = int(self.getConfig('failure-amount', 3)) self.failure_amount = int(self.getConfig('failure-amount', 3))
......
...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise): ...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=2) self.setPeriodicity(float(self.getConfig('frequency', 2)))
def sense(self): def sense(self):
process_pid_file = self.getConfig('process-pid-file') process_pid_file = self.getConfig('process-pid-file')
......
...@@ -11,7 +11,7 @@ except ImportError: ...@@ -11,7 +11,7 @@ except ImportError:
class RunPromise(GenericPromise): class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
self.setPeriodicity(minute=int(self.getConfig('frequency', 5))) self.setPeriodicity(minute=float(self.getConfig('frequency', 5)))
def sense(self): def sense(self):
""" """
......
...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise): ...@@ -11,7 +11,7 @@ class RunPromise(GenericPromise):
def __init__(self, config): def __init__(self, config):
super(RunPromise, self).__init__(config) super(RunPromise, self).__init__(config)
# check configuration every 5 minutes (only for anomaly) # check configuration every 5 minutes (only for anomaly)
self.setPeriodicity(minute=int(self.getConfig('frequency', 5))) self.setPeriodicity(minute=float(self.getConfig('frequency', 5)))
def sense(self): def sense(self):
""" """
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment