]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/ssh: fix update_rgw, update_mgr
authorSage Weil <sage@redhat.com>
Fri, 8 Nov 2019 15:23:49 +0000 (09:23 -0600)
committerSage Weil <sage@redhat.com>
Fri, 8 Nov 2019 16:12:34 +0000 (10:12 -0600)
Signed-off-by: Sage Weil <sage@redhat.com>
src/pybind/mgr/ssh/module.py

index 268513660dc0c0bf12e4e64df998469625c196c0..51220703eeb233851e3520bd3ef5e6bd25664449 100644 (file)
@@ -944,8 +944,9 @@ class SSHOrchestrator(MgrModule, orchestrator.OrchestratorClientMixin):
             if num_to_remove > 0:
                 for daemon in daemons:
                     result = self._worker_pool.apply_async(
-                        self._remove_mgr,
-                        (daemon.service_instance, daemon.nodename))
+                        self._remove_daemon,
+                        ('%s.%s' % (d.service_type, d.service_instance),
+                         d.nodename))
                     results.append(result)
                     num_to_remove -= 1
                     if num_to_remove == 0:
@@ -1096,7 +1097,9 @@ class SSHOrchestrator(MgrModule, orchestrator.OrchestratorClientMixin):
             to_remove = len(daemons) - spec.count
             for d in daemons[0:to_remove]:
                 results.append(self._worker_pool.apply_async(
-                    self._remove_rgw, (d.service_instance, d.nodename)))
+                    self._remove_daemon,
+                    ('%s.%s' % (d.service_type, d.service_instance),
+                     d.nodename)))
         elif len(daemons) < spec.count:
             # add some
             spec.count -= len(daemons)