)
daemons.append(sd)
- @ forall_hosts
+ @forall_hosts
def create_func_map(*args: Any) -> str:
daemon_spec = self.cephadm_services[daemon_type].prepare_create(*args)
with self.async_timeout_handler(daemon_spec.host, f'cephadm deploy ({daemon_spec.daemon_type} daemon)'):
(f'The maximum number of {spec.service_type} daemons allowed with {host_count} hosts is {max(5, host_count)}.'))
elif spec.service_type != 'osd':
if spec.placement.count > (max_count * host_count):
- raise OrchestratorError((f'The maximum number of {spec.service_type} daemons allowed with {host_count} hosts is {host_count*max_count} ({host_count}x{max_count}).'
+ raise OrchestratorError((f'The maximum number of {spec.service_type} daemons allowed with {host_count} hosts is {host_count * max_count} ({host_count}x{max_count}).'
+ ' This limit can be adjusted by changing the mgr/cephadm/max_count_per_host config option'))
if spec.placement.count_per_host is not None and spec.placement.count_per_host > max_count and spec.service_type != 'osd':
assert osd_claims.filtered_by_host('host1') == ['0']
assert osd_claims.filtered_by_host('host1.domain.com') == ['0']
- @ pytest.mark.parametrize(
+ @pytest.mark.parametrize(
"ceph_services, cephadm_daemons, strays_expected, metadata",
# [ ([(daemon_type, daemon_id), ... ], [...], [...]), ... ]
[