'''
Get current snapshot schedule for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
scheds = self.client.list_snap_schedules(fs, path, recursive)
self.log.debug(f'recursive is {recursive}')
except CephfsConnectionException as e:
'''
Set a snapshot schedule for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
subvol = None
self.client.store_snap_schedule(fs,
'''
Remove a snapshot schedule for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
self.client.rm_snap_schedule(fs, abs_path, repeat, start)
except ValueError as e:
'''
Set a retention specification for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
self.client.add_retention_spec(fs, abs_path,
retention_spec_or_period,
'''
Remove a retention specification for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
self.client.rm_retention_spec(fs, abs_path,
retention_spec_or_period,
'''
Activate a snapshot schedule for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
self.client.activate_snap_schedule(fs, abs_path, repeat, start)
except ValueError as e:
'''
Deactivate a snapshot schedule for <path>
'''
+ rc, fs, err = self._validate_fs(fs)
+ if rc < 0:
+ return rc, fs, err
try:
- rc, fs, err = self._validate_fs(fs)
- if rc < 0:
- return rc, fs, err
abs_path = path
self.client.deactivate_snap_schedule(fs, abs_path, repeat, start)
except ValueError as e: