]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/cephadm: revert to OrchestratorClientMixin child 32006/head
authorSage Weil <sage@redhat.com>
Fri, 17 Jan 2020 18:56:30 +0000 (12:56 -0600)
committerSage Weil <sage@redhat.com>
Fri, 17 Jan 2020 18:56:40 +0000 (12:56 -0600)
self.mgr does not exist--I can't figure out what this 'mgr' reference
is and where it comes from.  So reverting to being a child for the time
being; we can clean this up later.

Signed-off-by: Sage Weil <sage@redhat.com>
src/pybind/mgr/cephadm/module.py

index 0cc405ba37e4e87e4ece41576446528aa80bb4dd..529ad0af3ab52627c3135b629fcb98ca53de09b0 100644 (file)
@@ -264,7 +264,7 @@ def with_services(service_type=None,
         return wrapper
     return decorator
 
-class CephadmOrchestrator(orchestrator.Orchestrator, MgrModule):
+class CephadmOrchestrator(MgrModule, orchestrator.OrchestratorClientMixin):
 
     _STORE_HOST_PREFIX = "host"
 
@@ -560,13 +560,11 @@ class CephadmOrchestrator(orchestrator.Orchestrator, MgrModule):
     def serve(self):
         # type: () -> None
         self.log.info("serve starting")
-        orch_client = orchestrator.OrchestratorClientMixin()
-        orch_client.set_mgr(self.mgr)
         while self.run:
             while self.upgrade_state and not self.upgrade_state.get('paused'):
                 self.log.debug('Upgrade in progress, refreshing services')
                 completion = self._get_services()
-                orch_client._orchestrator_wait([completion])
+                self._orchestrator_wait([completion])
                 orchestrator.raise_if_exception(completion)
                 self.log.debug('services %s' % completion.result)
                 completion = self._do_upgrade(completion.result)