import json
import logging
-from unittest import case
+from unittest import case, SkipTest
+
from cephfs_test_case import CephFSTestCase
from teuthology.exceptions import CommandFailedError
from tasks.ceph_manager import CephManager
from teuthology import misc as teuthology
+from tasks.cephfs.fuse_mount import FuseMount
log = logging.getLogger(__name__)
when the cluster appears to be unavailable.
"""
+ if not isinstance(self.mount_a, FuseMount):
+ raise SkipTest("Requires FUSE client to inject client metadata")
+
require_active = self.fs.get_config("fuse_require_active_mds", service_type="mon").lower() == "true"
if not require_active:
raise case.SkipTest("fuse_require_active_mds is not set")