return self._remove_daemons(args)
def remove_service(self, service_name):
- args = []
- for host, dm in self.cache.daemons.items():
- for name, d in dm.items():
- if d.matches_service(service_name):
- args.append(
- (d.name(), d.hostname, True)
- )
- self.log.info('Remove service %s (daemons %s)' % (
- service_name, [a[0] for a in args]))
+ self.log.info('Remove service %s' % service_name)
self.spec_store.rm(service_name)
- if args:
- return self._remove_daemons(args)
+ self._kick_serve_loop()
return trivial_result(['Removed service %s' % service_name])
def get_inventory(self, host_filter=None, refresh=False):
wait(cephadm_module, c)
c = cephadm_module.remove_service('rgw.myrgw')
out = wait(cephadm_module, c)
- assert out == ["Removed rgw.myrgw.foobar from host 'test'"]
+ assert out == ["Removed service rgw.myrgw"]
@mock.patch("cephadm.module.CephadmOrchestrator._run_cephadm", _run_cephadm('{}'))
def test_rbd_mirror(self, cephadm_module):