If job.check() fails job is stopped
"""
i = 0
+ overridden = []
while i < len(self.jobs):
job = self.jobs[i]
+ if job.name in overridden:
+ self._stop(job)
+ msg.error(job.name + " already exists")
try:
if not job.check():
self._stop(job, "failed check")
else:
msg.debug(job.chart_name, ": check succeeded")
i += 1
+ try:
+ if job.override_name is not None:
+ job.name = job.override_name
+ msg.debug(job.chart_name + " changing chart name to: " + job.__module__ + job.name)
+ job.chart_name = job.__module__ + job.name
+ overridden.append(job.name)
+ except Exception:
+ pass
except AttributeError:
self._stop(job, "no check")
except (UnboundLocalError, Exception) as e:
self.priority = 140000
self.update_every = 1
self.name = name
+ self.override_name = None
if configuration is None:
self.error("BaseService: no configuration parameters supplied. Cannot create Service.")
raise RuntimeError
'retries':0}
:param config: dict
"""
+ try:
+ self.override_name = config.pop('override_name')
+ except KeyError:
+ pass
self.update_every = int(config.pop('update_every'))
self.priority = int(config.pop('priority'))
self.retries = int(config.pop('retries'))