try:
status = json.loads(status['json'])
- except ValueError:
+ except (ValueError, KeyError) as _:
status = {}
instance_id = metadata['instance_id']
pool_names = [pool['pool_name'] for pool in CephService.get_pool_list('rbd')]
_, data = get_daemons_and_pools(self.mgr)
- if data is None:
- logger.warning("Failed to get rbd-mirror daemons list")
- data = {}
+ if isinstance(data, Exception):
+ logger.exception("Failed to get rbd-mirror daemons list")
+ raise type(data)(str(data))
daemons = data.get('daemons', [])
pool_stats = data.get('pools', {})