]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
qa/test_mirroring: Fix flake8 errors
authorKotresh HR <khiremat@redhat.com>
Mon, 16 Feb 2026 19:35:59 +0000 (01:05 +0530)
committerKotresh HR <khiremat@redhat.com>
Mon, 16 Feb 2026 19:53:42 +0000 (01:23 +0530)
Introduced-by: c1e827247bd20e8a1851bc2d7a9861c12d033ef0
Signed-off-by: Kotresh HR <khiremat@redhat.com>
qa/tasks/cephfs/test_mirroring.py

index 3708a344776b5b13df98f937830a961b586c11b2..73597a1d6742a50a48c365607e4934469f843e43 100644 (file)
@@ -43,8 +43,8 @@ def retry_assert(timeout=60, interval=1):
                         attempt += 1
             # Final failure
             if last_exc is not None and hasattr(last_exc, "res"):
-              log.error("\n--- Last peer status (res) ---")
-              log.error(last_exc.res)
+                log.error("\n--- Last peer status (res) ---")
+                log.error(last_exc.res)
 
             raise AssertionError(
                 f"{func.__name__} did not succeed within {timeout}s "
@@ -54,6 +54,7 @@ def retry_assert(timeout=60, interval=1):
         return wrapper
     return decorator
 
+
 class TestMirroring(CephFSTestCase):
     MDSS_REQUIRED = 5
     CLIENTS_REQUIRED = 2
@@ -329,7 +330,6 @@ class TestMirroring(CephFSTestCase):
     def check_peer_snap_in_progress(self, fs_name, fs_id,
                                     peer_spec, dir_name, snap_name, timeout=60, interval=1):
         peer_uuid = self.get_peer_uuid(peer_spec)
-        deadline = time.time() + timeout
         try:
             res = self.mirror_daemon_command(f'peer status for fs: {fs_name}',
                                              'fs', 'mirror', 'peer', 'status',