import 15.2.4

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

diff --git a/ceph/qa/tasks/peer.py b/ceph/qa/tasks/peer.py
index 9850da18e55d286e459b730e2dd02f8f7530f04b..6b19096b15a1392f6ec390085e5bd379a168d948 100644 (file)
--- a/ceph/qa/tasks/peer.py
+++ b/ceph/qa/tasks/peer.py
@@ -5,9 +5,9 @@ import logging
 import json
 import time
 
-import ceph_manager
+from tasks import ceph_manager
+from tasks.util.rados import rados
 from teuthology import misc as teuthology
-from util.rados import rados
 
 log = logging.getLogger(__name__)
 
@@ -20,7 +20,7 @@ def task(ctx, config):
     assert isinstance(config, dict), \
         'peer task only accepts a dict for configuration'
     first_mon = teuthology.get_first_mon(ctx, config)
-    (mon,) = ctx.cluster.only(first_mon).remotes.iterkeys()
+    (mon,) = ctx.cluster.only(first_mon).remotes.keys()
 
     manager = ceph_manager.CephManager(
         mon,
@@ -65,7 +65,7 @@ def task(ctx, config):
     pgs = manager.get_pg_stats()
     for pg in pgs:
         out = manager.raw_cluster_cmd('pg', pg['pgid'], 'query')
-       log.debug("out string %s",out)
+        log.debug("out string %s",out)
         j = json.loads(out)
         log.info("pg is %s, query json is %s", pg, j)