]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
mgr/volumes/fs: add extra blank line 43322/head
authorManasviGoyal <mg.manasvi@gmail.com>
Mon, 27 Sep 2021 17:44:26 +0000 (23:14 +0530)
committerManasviGoyal <mg.manasvi@gmail.com>
Mon, 27 Sep 2021 17:44:26 +0000 (23:14 +0530)
Fixes: https://tracker.ceph.com/issues/51387
Signed-off-by: Manasvi Goyal <mg.manasvi@gmail.com>
src/pybind/mgr/volumes/fs/purge_queue.py

index d67ef9af373f6fcaaf347c4ca5695ec42e78115b..d444daa91c3a85e458dd3a1865958caa4602d093 100644 (file)
@@ -16,6 +16,7 @@ from .operations.trash import open_trashcan
 
 log = logging.getLogger(__name__)
 
+
 # helper for fetching a trash entry for a given volume
 def get_trash_entry_for_volume(fs_client, volspec, volname, running_jobs):
     log.debug("fetching trash entry for volume '{0}'".format(volname))
@@ -34,6 +35,7 @@ def get_trash_entry_for_volume(fs_client, volspec, volname, running_jobs):
         log.error("error fetching trash entry for volume '{0}' ({1})".format(volname, ve))
         return ve.errno, None
 
+
 def subvolume_purge(fs_client, volspec, volname, trashcan, subvolume_trash_entry, should_cancel):
     groupname, subvolname = resolve_trash(volspec, subvolume_trash_entry.decode('utf-8'))
     log.debug("subvolume resolved to {0}/{1}".format(groupname, subvolname))
@@ -53,6 +55,7 @@ def subvolume_purge(fs_client, volspec, volname, trashcan, subvolume_trash_entry
         if not ve.errno == -errno.ENOENT:
             raise
 
+
 # helper for starting a purge operation on a trash entry
 def purge_trash_entry_for_volume(fs_client, volspec, volname, purge_entry, should_cancel):
     log.debug("purging trash entry '{0}' for volume '{1}'".format(purge_entry, volname))
@@ -90,6 +93,7 @@ def purge_trash_entry_for_volume(fs_client, volspec, volname, purge_entry, shoul
         ret = ve.errno
     return ret
 
+
 class ThreadPoolPurgeQueueMixin(AsyncJobs):
     """
     Purge queue mixin class maintaining a pool of threads for purging trash entries.