output = self._cmd('auth', 'ls')
client_id = f'client.nfs.{self.cluster_id}'
if check_in:
- self.assertIn(f'{cient_id}.{export_id}', output)
+ self.assertIn(f'{client_id}.{export_id}', output)
else:
- self.assertNotIn(client_id, output)
+ self.assertNotIn(f'{client_id}.{export_id}', output)
def _test_idempotency(self, cmd_func, cmd_args):
'''
new_pseudo_path = '/testing'
export_block['pseudo'] = new_pseudo_path
export_block['access_type'] = 'RO'
- self.ctx.cluster.run(args=['sudo', 'ceph', 'nfs', 'export', 'update',
+ self.ctx.cluster.run(args=['sudo', 'ceph', 'nfs', 'export', 'apply',
self.cluster_id, '-i', '-'],
stdin=json.dumps(export_block))
self._check_nfs_cluster_status('running', 'NFS Ganesha cluster restart failed')
else:
export_block_new[key] = value
try:
- self.ctx.cluster.run(args=['sudo', 'ceph', 'nfs', 'export', 'update',
+ self.ctx.cluster.run(args=['sudo', 'ceph', 'nfs', 'export', 'apply',
self.cluster_id, '-i', '-'],
stdin=json.dumps(export_block_new))
except CommandFailedError:
exec_cmd_invalid('export', 'delete', 'clusterid')
exec_cmd_invalid('export', 'info')
exec_cmd_invalid('export', 'info', 'clusterid')
- exec_cmd_invalid('export', 'update')
+ exec_cmd_invalid('export', 'apply')