ctx.daemons.get_daemon(type_, id_, cluster).restart()
clusters.add(cluster)
- for cluster in clusters:
- manager = ctx.managers[cluster]
- for dmon in daemons:
- if '.' in dmon:
- dm_parts = dmon.split('.')
- if dm_parts[1].isdigit():
- if dm_parts[0] == 'osd':
- manager.mark_down_osd(int(dm_parts[1]))
+ for role in daemons:
+ cluster, type_, id_ = teuthology.split_role(role)
+ if type_ == 'osd':
+ ctx.managers[cluster].mark_down_osd(id_)
if config.get('wait-for-healthy', True):
for cluster in clusters: