"""
(daemon_type, daemon_id) = name.split('.', 1)
- self.cephadm_services[daemon_type].pre_remove(daemon_id)
+ with set_exception_subject('service', orchestrator.DaemonDescription(
+ daemon_type=daemon_type,
+ daemon_id=daemon_id,
+ hostname=host,
+ ).service_id(), overwrite=True):
+
- args = ['--name', name, '--force']
- self.log.info('Removing daemon %s from %s' % (name, host))
- out, err, code = self._run_cephadm(
- host, name, 'rm-daemon', args)
- if not code:
- # remove item from cache
- self.cache.rm_daemon(host, name)
- self.cache.invalidate_host_daemons(host)
- return "Removed {} from host '{}'".format(name, host)
+ self.cephadm_services[daemon_type].pre_remove(daemon_id)
+
+ args = ['--name', name, '--force']
+ self.log.info('Removing daemon %s from %s' % (name, host))
+ out, err, code = self._run_cephadm(
+ host, name, 'rm-daemon', args)
+ if not code:
+ # remove item from cache
+ self.cache.rm_daemon(host, name)
+ self.cache.invalidate_host_daemons(host)
+ return "Removed {} from host '{}'".format(name, host)
def _config_fn(self, service_type) -> Optional[Callable[[ServiceSpec], None]]:
- return {
+ fn = {
'mds': self.mds_service.config,
'rgw': self.rgw_service.config,
'nfs': self.nfs_service.config,