diff --git a/actions/add_disk.py b/actions/add_disk.py index 9e303494ce95a5a2ea9638491c8da759867b2cab..123fa7fb1e4937ca60d2d1c07db984797f44d9bb 100755 --- a/actions/add_disk.py +++ b/actions/add_disk.py @@ -31,7 +31,10 @@ from charmhelpers.contrib.storage.linux.ceph import ( send_request_if_needed, ) -import ceph +from ceph.utils import ( + osdize, + tune_dev, +) from ceph_hooks import ( get_journal_devices, @@ -39,14 +42,14 @@ from ceph_hooks import ( def add_device(request, device_path, bucket=None): - ceph.osdize(dev, config('osd-format'), - get_journal_devices(), config('osd-reformat'), - config('ignore-device-errors'), - config('osd-encrypt'), - config('bluestore')) + osdize(dev, config('osd-format'), + get_journal_devices(), config('osd-reformat'), + config('ignore-device-errors'), + config('osd-encrypt'), + config('bluestore')) # Make it fast! if config('autotune'): - ceph.tune_dev(dev) + tune_dev(dev) mounts = filter(lambda disk: device_path in disk.device, psutil.disk_partitions()) if mounts: diff --git a/actions/list_disks.py b/actions/list_disks.py index f92a3b690ec805d83fba7e7f913d3f041e1e0c58..7bf971f60c0fef8697268c0538990ab9e8462d47 100755 --- a/actions/list_disks.py +++ b/actions/list_disks.py @@ -28,7 +28,7 @@ sys.path.append('lib/') from charmhelpers.core.hookenv import action_set -from ceph import unmounted_disks +from ceph.utils import unmounted_disks if __name__ == '__main__': action_set({ diff --git a/actions/replace_osd.py b/actions/replace_osd.py index edfa1f7b841001e89a7196aacb3bcc9a8aa1b389..b23a10d783d045c1785d236aba859c9aff8eb1e3 100755 --- a/actions/replace_osd.py +++ b/actions/replace_osd.py @@ -22,7 +22,9 @@ sys.path.append('lib/') from charmhelpers.core.hookenv import action_get, log, config, action_fail -import ceph +from ceph.utils import ( + replace_osd, +) """ Given a OSD number this script will attempt to turn that back into a mount @@ -90,8 +92,8 @@ if __name__ == '__main__': osd_format = config('osd-format') osd_journal = config('osd-journal') - ceph.replace_osd(dead_osd_number=dead_osd_number, - dead_osd_device="/dev/{}".format(device_name), - new_osd_device=replacement_device, - osd_format=osd_format, - osd_journal=osd_journal) + replace_osd(dead_osd_number=dead_osd_number, + dead_osd_device="/dev/{}".format(device_name), + new_osd_device=replacement_device, + osd_format=osd_format, + osd_journal=osd_journal)