qa/tasks: drop python2 support

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/qa/tasks/autotest.py b/qa/tasks/autotest.py
index a78987dca70e79843f570301bcdaafd38a6acc55..297c1a4cbb71476b8a60ca1723426746c52bcdb2 100644 (file)
--- a/qa/tasks/autotest.py
+++ b/qa/tasks/autotest.py
@@ -5,8 +5,6 @@ import json
 import logging
 import os
 
-import six
-
 from teuthology import misc as teuthology
 from teuthology.parallel import parallel
 from teuthology.orchestra import run
@@ -50,7 +48,7 @@ def task(ctx, config):
 
     log.info('Making a separate scratch dir for every client...')
     for role in config.keys():
-        assert isinstance(role, six.string_types)
+        assert isinstance(role, str)
         PREFIX = 'client.'
         assert role.startswith(PREFIX)
         id_ = role[len(PREFIX):]
@@ -105,7 +103,7 @@ def _run_tests(testdir, remote, role, tests):
     """
     Spawned to run test on remote site
     """
-    assert isinstance(role, six.string_types)
+    assert isinstance(role, str)
     PREFIX = 'client.'
     assert role.startswith(PREFIX)
     id_ = role[len(PREFIX):]

diff --git a/qa/tasks/cram.py b/qa/tasks/cram.py
index d06f09440a6a5fcdcc7fe798643dc77e8de50601..8a2189d40994aaab30b9c0c025a19b48234bf639 100644 (file)
--- a/qa/tasks/cram.py
+++ b/qa/tasks/cram.py
@@ -4,8 +4,6 @@ Cram tests
 import logging
 import os
 
-import six
-
 from tasks.util.workunit import get_refspec_after_overrides
 
 from teuthology import misc as teuthology
@@ -126,7 +124,7 @@ def _run_tests(ctx, role):
     :param ctx: Context
     :param role: Roles
     """
-    assert isinstance(role, six.string_types)
+    assert isinstance(role, str)
     PREFIX = 'client.'
     assert role.startswith(PREFIX)
     id_ = role[len(PREFIX):]

diff --git a/qa/tasks/devstack.py b/qa/tasks/devstack.py
index 9243071a4bf01136dda4ed844394e755334b35e7..e3bba302b0d5095c7a3d4a9d952e3e066abd9630 100644 (file)
--- a/qa/tasks/devstack.py
+++ b/qa/tasks/devstack.py
@@ -1,12 +1,10 @@
 #!/usr/bin/env python
 import contextlib
 import logging
-from io import BytesIO
 import textwrap
-from configparser import ConfigParser
-
-import six
 import time
+from configparser import ConfigParser
+from io import BytesIO, StringIO
 
 from teuthology.orchestra import run
 from teuthology import misc
@@ -206,7 +204,7 @@ def update_devstack_config_files(devstack_node, secret_uuid):
         parser.read_file(config_stream)
         for (key, value) in update_dict.items():
             parser.set(section, key, value)
-        out_stream = six.StringIO()
+        out_stream = StringIO()
         parser.write(out_stream)
         out_stream.seek(0)
         return out_stream
@@ -251,7 +249,7 @@ def update_devstack_config_files(devstack_node, secret_uuid):
         file_name = update['name']
         options = update['options']
         config_data = misc.get_file(devstack_node, file_name, sudo=True)
-        config_stream = six.StringIO(config_data)
+        config_stream = StringIO(config_data)
         backup_config(devstack_node, file_name)
         new_config_stream = update_config(file_name, config_stream, options)
         misc.sudo_write_file(devstack_node, file_name, new_config_stream)

diff --git a/qa/tasks/omapbench.py b/qa/tasks/omapbench.py
index af0793d956447e1fabfcb5d871e62bfa60035e61..a5bd3a4df23fbe9eea18fefa55800e6cd53f67eb 100644 (file)
--- a/qa/tasks/omapbench.py
+++ b/qa/tasks/omapbench.py
@@ -4,8 +4,6 @@ Run omapbench executable within teuthology
 import contextlib
 import logging
 
-import six
-
 from teuthology.orchestra import run
 from teuthology import misc as teuthology
 
@@ -50,7 +48,7 @@ def task(ctx, config):
     testdir = teuthology.get_testdir(ctx)
     print(str(config.get('increment',-1)))
     for role in config.get('clients', ['client.0']):
-        assert isinstance(role, six.string_types)
+        assert isinstance(role, str)
         PREFIX = 'client.'
         assert role.startswith(PREFIX)
         id_ = role[len(PREFIX):]

diff --git a/qa/tasks/rados.py b/qa/tasks/rados.py
index edce8dc805bf969b4bd10b36afe16bdb3c8302f2..349f46efcc9501019f494f0c0c494f5a35b2818e 100644 (file)
--- a/qa/tasks/rados.py
+++ b/qa/tasks/rados.py
@@ -6,7 +6,6 @@ import logging
 import gevent
 from teuthology import misc as teuthology
 
-import six
 
 from teuthology.orchestra import run
 
@@ -231,7 +230,7 @@ def task(ctx, config):
             existing_pools = config.get('pools', [])
             created_pools = []
             for role in config.get('clients', clients):
-                assert isinstance(role, six.string_types)
+                assert isinstance(role, str)
                 PREFIX = 'client.'
                 assert role.startswith(PREFIX)
                 id_ = role[len(PREFIX):]

diff --git a/qa/tasks/radosbench.py b/qa/tasks/radosbench.py
index a2c4f069353ec1ce66221f012795e11a6fd79732..0804840c5921a5456f3f61ca673fc0c20cf15732 100644 (file)
--- a/qa/tasks/radosbench.py
+++ b/qa/tasks/radosbench.py
@@ -7,7 +7,6 @@ import logging
 from teuthology.orchestra import run
 from teuthology import misc as teuthology
 
-import six
 
 log = logging.getLogger(__name__)
 
@@ -55,7 +54,7 @@ def task(ctx, config):
 
     create_pool = config.get('create_pool', True)
     for role in config.get('clients', ['client.0']):
-        assert isinstance(role, six.string_types)
+        assert isinstance(role, str)
         PREFIX = 'client.'
         assert role.startswith(PREFIX)
         id_ = role[len(PREFIX):]

diff --git a/qa/tasks/radosbenchsweep.py b/qa/tasks/radosbenchsweep.py
index 0aeb7218681c3858e2b9b47d4833dbf5692bb6b7..df0ba1ed1c5aef9922bab5efe4e8a9dd8f7e15a4 100644 (file)
--- a/qa/tasks/radosbenchsweep.py
+++ b/qa/tasks/radosbenchsweep.py
@@ -11,7 +11,6 @@ from itertools import product
 from teuthology.orchestra import run
 from teuthology import misc as teuthology
 
-import six
 
 log = logging.getLogger(__name__)
 
@@ -169,7 +168,7 @@ def run_radosbench(ctx, config, f, num_osds, size, replica, rep):
     log.info('  repetition =' + str(rep))
 
     for role in config.get('clients', ['client.0']):
-        assert isinstance(role, six.string_types)
+        assert isinstance(role, str)
         PREFIX = 'client.'
         assert role.startswith(PREFIX)
         id_ = role[len(PREFIX):]

diff --git a/qa/tasks/watch_notify_same_primary.py b/qa/tasks/watch_notify_same_primary.py
index 7c034961c3824f6abc378f539ea2e7b2f5976203..448fee193ca1cf42755ba1f4090664831ba83275 100644 (file)
--- a/qa/tasks/watch_notify_same_primary.py
+++ b/qa/tasks/watch_notify_same_primary.py
@@ -2,11 +2,10 @@
 """
 watch_notify_same_primary task
 """
-from six import StringIO
+from io import StringIO
 import contextlib
 import logging
 
-import six
 
 from teuthology.orchestra import run
 from teuthology.contextutil import safe_while
@@ -43,7 +42,7 @@ def task(ctx, config):
     clients = config.get('clients', ['client.0'])
     assert len(clients) == 1
     role = clients[0]
-    assert isinstance(role, six.string_types)
+    assert isinstance(role, str)
     PREFIX = 'client.'
     assert role.startswith(PREFIX)
     (remote,) = ctx.cluster.only(role).remotes.keys()

diff --git a/qa/tasks/watch_notify_stress.py b/qa/tasks/watch_notify_stress.py
index e5e380492e0e8038d6edbcfd63183a88c6698ee8..47747b1ca018e41961d79406a3d25a8fdd5ca6c0 100644 (file)
--- a/qa/tasks/watch_notify_stress.py
+++ b/qa/tasks/watch_notify_stress.py
@@ -4,7 +4,6 @@ test_stress_watch task
 import contextlib
 import logging
 
-import six
 from teuthology.orchestra import run
 from teuthology.task import proc_thrasher
 
@@ -37,7 +36,7 @@ def task(ctx, config):
     remotes = []
 
     for role in config.get('clients', ['client.0']):
-        assert isinstance(role, six.string_types)
+        assert isinstance(role, str)
         PREFIX = 'client.'
         assert role.startswith(PREFIX)
         id_ = role[len(PREFIX):]

diff --git a/qa/workunits/mon/caps.py b/qa/workunits/mon/caps.py
index 0268851b3b9503dafc3e9e987f1a6c9245fe920d..26c0cd14ccb895d667ef89468e29954870ba9edd 100644 (file)
--- a/qa/workunits/mon/caps.py
+++ b/qa/workunits/mon/caps.py
@@ -10,8 +10,6 @@ import os
 import io
 import re
 
-import six
-
 from ceph_argparse import * # noqa
 
 keyring_base = '/tmp/cephtest-caps.keyring'
@@ -21,8 +19,7 @@ class UnexpectedReturn(Exception):
     if isinstance(cmd, list):
       self.cmd = ' '.join(cmd)
     else:
-      assert isinstance(cmd, str) or isinstance(cmd, six.text_type), \
-          'cmd needs to be either a list or a str'
+      assert isinstance(cmd, str), 'cmd needs to be either a list or a str'
       self.cmd = cmd
     self.cmd = str(self.cmd)
     self.ret = int(ret)
@@ -36,7 +33,7 @@ class UnexpectedReturn(Exception):
 def call(cmd):
   if isinstance(cmd, list):
     args = cmd
-  elif isinstance(cmd, str) or isinstance(cmd, six.text_type):
+  elif isinstance(cmd, str):
     args = shlex.split(cmd)
   else:
     assert False, 'cmd is not a string/unicode nor a list!'
@@ -64,15 +61,15 @@ def expect(cmd, expected_ret):
 
   return p
 
-def expect_to_file(cmd, expected_ret, out_file, mode='a'):
+def expect_to_file(cmd, expected_ret, out_file):
 
   # Let the exception be propagated to the caller
   p = expect(cmd, expected_ret)
   assert p.returncode == expected_ret, \
       'expected result doesn\'t match and no exception was thrown!'
 
-  with io.open(out_file, mode) as file:
-    file.write(six.text_type(p.stdout.read()))
+  with io.open(out_file, 'ab') as file:
+    file.write(p.stdout.read())
 
   return p
 
@@ -86,7 +83,7 @@ class Command:
     self.args = []
     for s in j['sig']:
       if not isinstance(s, dict):
-        assert isinstance(s, str) or isinstance(s,six.text_type), \
+        assert isinstance(s, str), \
             'malformatted signature cid {0}: {1}\n{2}'.format(cid,s,j)
         if len(self.sig) > 0:
           self.sig += ' '

diff --git a/qa/workunits/mon/ping.py b/qa/workunits/mon/ping.py
index edbd586026b62361f404163e86c15b5f0263b72d..1f6d0a1ddcb2f8e040946666310673271bfdd74d 100755 (executable)
--- a/qa/workunits/mon/ping.py
+++ b/qa/workunits/mon/ping.py
@@ -4,15 +4,13 @@ import json
 import shlex
 import subprocess
 
-import six
-
 
 class UnexpectedReturn(Exception):
     def __init__(self, cmd, ret, expected, msg):
         if isinstance(cmd, list):
             self.cmd = ' '.join(cmd)
         else:
-            assert isinstance(cmd, six.string_types) or isinstance(cmd, six.text_type), \
+            assert isinstance(cmd, str), \
                 'cmd needs to be either a list or a str'
             self.cmd = cmd
         self.cmd = str(self.cmd)
@@ -28,7 +26,7 @@ class UnexpectedReturn(Exception):
 def call(cmd):
     if isinstance(cmd, list):
         args = cmd
-    elif isinstance(cmd, six.string_types) or isinstance(cmd, six.text_type):
+    elif isinstance(cmd, str):
         args = shlex.split(cmd)
     else:
         assert False, 'cmd is not a string/unicode nor a list!'

diff --git a/src/powerdns/pdns-backend-rgw.py b/src/powerdns/pdns-backend-rgw.py
index b943ed9b421be1091fc5f8d30c13eff1923bca1d..5d773d2aabddc7938c8bf1f9235039124d1adaf3 100755 (executable)
--- a/src/powerdns/pdns-backend-rgw.py
+++ b/src/powerdns/pdns-backend-rgw.py
@@ -53,7 +53,7 @@ from ConfigParser import SafeConfigParser, NoSectionError
 from flask import abort, Flask, request, Response
 from hashlib import sha1 as sha
 from time import gmtime, strftime
-from six.moves.urllib.parse import urlparse
+from urllib.parse import urlparse
 import argparse
 import base64
 import hmac