update sources to v12.1.0

[ceph.git] / ceph / qa / tasks / divergent_priors.py

diff --git a/ceph/qa/tasks/divergent_priors.py b/ceph/qa/tasks/divergent_priors.py
index 6ee376d0a928a9401133e15c4a1b6d50e3d1323d..12ea93365bf396efa79b7b0a34844c64c2937a4f 100644 (file)
--- a/ceph/qa/tasks/divergent_priors.py
+++ b/ceph/qa/tasks/divergent_priors.py
@@ -33,9 +33,7 @@ def task(ctx, config):
 
     while len(manager.get_osd_status()['up']) < 3:
         time.sleep(10)
-    manager.raw_cluster_cmd('tell', 'osd.0', 'flush_pg_stats')
-    manager.raw_cluster_cmd('tell', 'osd.1', 'flush_pg_stats')
-    manager.raw_cluster_cmd('tell', 'osd.2', 'flush_pg_stats')
+    manager.flush_pg_stats([0, 1, 2])
     manager.raw_cluster_cmd('osd', 'set', 'noout')
     manager.raw_cluster_cmd('osd', 'set', 'noin')
     manager.raw_cluster_cmd('osd', 'set', 'nodown')