class NFSException(Exception):
- def __init__(self, errno: int, err_msg: str) -> None:
+ def __init__(self, err_msg: str, errno: int = -1) -> None:
super(NFSException, self).__init__(errno, err_msg)
self.errno = errno
self.err_msg = err_msg
class NFSInvalidOperation(NFSException):
def __init__(self, err_msg: str) -> None:
- super(NFSInvalidOperation, self).__init__(-errno.EINVAL, err_msg)
+ super(NFSInvalidOperation, self).__init__(err_msg, -errno.EINVAL)
class NFSObjectNotFound(NFSException):
def __init__(self, err_msg: str) -> None:
- super(NFSObjectNotFound, self).__init__(-errno.ENOENT, err_msg)
+ super(NFSObjectNotFound, self).__init__(err_msg, -errno.ENOENT)
class FSNotFound(NFSObjectNotFound):
ret, out, err = self._delete_export(cluster_id=cluster_id, pseudo_path=None,
export_obj=export)
if ret != 0:
- raise NFSException(-1, f"Failed to delete exports: {err} and {ret}")
+ raise NFSException(f"Failed to delete exports: {err} and {ret}")
log.info(f"All exports successfully deleted for cluster id: {cluster_id}")
@export_cluster_checker
ret, out, err = self._exec(['radosgw-admin', 'user', 'create', '--uid', uid,
'--display-name', uid])
if ret:
- raise NFSException(-1, f'Failed to create user {uid}')
+ raise NFSException(f'Failed to create user {uid}')
j = json.loads(out)
# FIXME: make this more tolerate of unexpected output?
access_key = j['keys'][0]['access_key']