pool_id = self._create_volume_pool(pool_name)
mds_map = self.get_mds_map()
if pool_id not in mds_map['data_pools']:
- self._rados_command("fs {} add_data_pool".format(mds_map['fs_name']), {
+ self._rados_command("fs add_data_pool", {
+ 'fs_name': mds_map['fs_name'],
'pool': pool_name
})
time.sleep(5) # time for MDSMap to be distributed
pool_id = self._get_pool_id(osd_map, pool_name)
mds_map = self.get_mds_map()
if pool_id in mds_map['data_pools']:
- self._rados_command("fs {} rm_data_pool".format(mds_map['fs_name']), {
+ self._rados_command("fs rm_data_pool", {
+ 'fs_name': mds_map['fs_name'],
'pool': pool_name
})
self._rados_command("osd pool delete",