Fixes: http://tracker.ceph.com/issues/42835
Signed-off-by: Venky Shankar <vshankar@redhat.com>
return self.fs.rank_tell(["scrub", "status"])
def _check_task_status(self, expected_status):
task_status = self.fs.get_task_status("scrub status")
- self.assertTrue(task_status['0'].startswith(expected_status))
+ active = self.fs.get_active_names()
+ log.debug("current active={0}".format(active))
+ self.assertTrue(task_status[active[0]].startswith(expected_status))
def test_scrub_abort(self):
test_dir = "scrub_control_test_path"