From: Sage Weil Date: Tue, 3 Aug 2021 18:36:39 +0000 (-0400) Subject: mgr/orchestrator: accept --method arg to 'orch daemon add osd' X-Git-Tag: v16.2.11~576^2~11 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=6b2d817ee6d818dedc3b6ef09a72b84b6bc7f732;p=ceph.git mgr/orchestrator: accept --method arg to 'orch daemon add osd' Signed-off-by: Sage Weil (cherry picked from commit cef129d90abd73536a141fb375ce35cc7e5081a4) Conflicts: src/pybind/mgr/orchestrator/module.py --- diff --git a/src/pybind/mgr/orchestrator/module.py b/src/pybind/mgr/orchestrator/module.py index b26be92fd2dd..f4646b3ddb81 100644 --- a/src/pybind/mgr/orchestrator/module.py +++ b/src/pybind/mgr/orchestrator/module.py @@ -9,7 +9,7 @@ import yaml from prettytable import PrettyTable from ceph.deployment.inventory import Device -from ceph.deployment.drive_group import DriveGroupSpec, DeviceSelection +from ceph.deployment.drive_group import DriveGroupSpec, DeviceSelection, OSDMethod from ceph.deployment.service_spec import PlacementSpec, ServiceSpec, service_spec_allow_invalid_from_json from ceph.deployment.hostspec import SpecValidationError from ceph.utils import datetime_now @@ -777,7 +777,9 @@ class OrchestratorCli(OrchestratorClientMixin, MgrModule, return HandleCommandResult(-errno.EINVAL, stderr='--all-available-devices is required') @_cli_write_command('orch daemon add osd') - def _daemon_add_osd(self, svc_arg: Optional[str] = None) -> HandleCommandResult: + def _daemon_add_osd(self, + svc_arg: Optional[str] = None, + method: Optional[OSDMethod] = None) -> HandleCommandResult: """Create an OSD service. Either --svc_arg=host:drives""" # Create one or more OSDs""" @@ -794,9 +796,10 @@ Usage: drive_group = DriveGroupSpec( placement=PlacementSpec(host_pattern=host_name), data_devices=devs, + method=method, ) except (TypeError, KeyError, ValueError) as e: - msg = f"Invalid 'host:device' spec: '{svc_arg}': {e}" + usage + msg = f"Invalid host:device spec: '{svc_arg}': {e}" + usage return HandleCommandResult(-errno.EINVAL, stderr=msg) completion = self.create_osds(drive_group)