def serve(self):
# type: () -> None
- self.log.info("serve starting")
+ self.log.debug("serve starting")
while self.run:
self._check_hosts()
+ self._remove_osds_bg()
# refresh daemons
self.log.debug('refreshing hosts')
args.append((name, host, force))
if not args:
raise OrchestratorError('Unable to find daemon(s) %s' % (names))
+ self.log.info('Remove daemons %s' % [a[0] for a in args])
return self._remove_daemon(args)
- def remove_service(self, service_name):
+ def remove_service(self, service_name, force=False):
args = []
for host, dm in self.cache.daemons.items():
for name, d in dm.items():
if d.matches_service(service_name):
args.append(
- ('%s.%s' % (d.daemon_type, d.daemon_id), d.hostname, force)
- (d.name(), d.hostname)
++ (d.name(), d.hostname, force)
)
if not args:
raise OrchestratorError('Unable to find daemons in %s service' % (