:param module_options: Set opts as if they were set before module.__init__ is called
:param store: Set the store before module.__init__ is called
"""
- with mock.patch("cephadm.module.CephadmOrchestrator.get_ceph_option", get_ceph_option),\
+ with mock.patch("cephadm.module.CephadmOrchestrator.get_ceph_option", get_ceph_option), \
mock.patch("cephadm.services.osd.RemoveUtil._run_mon_cmd"), \
- mock.patch('cephadm.module.CephadmOrchestrator.get_module_option_ex', get_module_option_ex),\
+ mock.patch('cephadm.module.CephadmOrchestrator.get_module_option_ex', get_module_option_ex), \
mock.patch("cephadm.module.CephadmOrchestrator.get_osdmap"), \
mock.patch("cephadm.module.CephadmOrchestrator.remote"), \
mock.patch("cephadm.agent.CephadmAgentHelpers._request_agent_acks"), \
cephadm_module.set_container_image('global', 'from_image')
cephadm_module.use_repo_digest = use_repo_digest
with with_service(cephadm_module, ServiceSpec('mgr', placement=PlacementSpec(host_pattern='*', count=2)),
- CephadmOrchestrator.apply_mgr, '', status_running=True),\
+ CephadmOrchestrator.apply_mgr, '', status_running=True), \
mock.patch("cephadm.module.CephadmOrchestrator.lookup_release_name",
- return_value='foo'),\
+ return_value='foo'), \
mock.patch("cephadm.module.CephadmOrchestrator.version",
- new_callable=mock.PropertyMock) as version_mock,\
+ new_callable=mock.PropertyMock) as version_mock, \
mock.patch("cephadm.module.CephadmOrchestrator.get",
return_value={
# capture fields in both mon and osd maps
from prettytable import PrettyTable
import re
from threading import Event, Lock
-from typing import cast, Any, Callable, DefaultDict, Dict, Iterable, List, Optional, Tuple, TypeVar,\
+from typing import cast, Any, Callable, DefaultDict, Dict, Iterable, List, Optional, Tuple, TypeVar, \
Union, TYPE_CHECKING