refactor(tests): Clean up old PEP-249 tests

* Use the `unittest` module's `assert` in unit tests.
* Drop legacy branching for unsupported 2.7
* Eliminate unused variables
* Remove superfluous initializations
* Use unpack assignments

Signed-off-by: Ferenc Géczi <ferenc.geczi@ibm.com>

tests/clients/test_mysqlclient.py

@@ -11,10 +11,7 @@
 from instana.singletons import tracer
 
 
-if sys.version_info[0] > 2:
-    import MySQLdb
-else:
-    raise SkipTest("mysqlclient supported on Python 3 only")
+import MySQLdb
 
 logger = logging.getLogger(__name__)
 
@@ -75,24 +72,22 @@ def test_vanilla_query(self):
         self.assertEqual(0, len(spans))
 
     def test_basic_query(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.execute("""SELECT * from users""")
             self.cursor.fetchone()
 
-        assert(result >= 0)
+        self.assertTrue(result >= 0)
 
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "mysql")
         self.assertEqual(db_span.data["mysql"]["db"], testenv['mysql_db'])
@@ -102,7 +97,6 @@ def test_basic_query(self):
         self.assertEqual(db_span.data["mysql"]["port"], testenv['mysql_port'])
 
     def test_basic_insert(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.execute(
                         """INSERT INTO users(name, email) VALUES(%s, %s)""",
@@ -113,14 +107,13 @@ def test_basic_insert(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "mysql")
         self.assertEqual(db_span.data["mysql"]["db"], testenv['mysql_db'])
@@ -130,7 +123,6 @@ def test_basic_insert(self):
         self.assertEqual(db_span.data["mysql"]["port"], testenv['mysql_port'])
 
     def test_executemany(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.executemany("INSERT INTO users(name, email) VALUES(%s, %s)",
                                              [('beaker', 'beaker@muppets.com'), ('beaker', 'beaker@muppets.com')])
@@ -141,14 +133,13 @@ def test_executemany(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "mysql")
         self.assertEqual(db_span.data["mysql"]["db"], testenv['mysql_db'])
@@ -158,23 +149,21 @@ def test_executemany(self):
         self.assertEqual(db_span.data["mysql"]["port"], testenv['mysql_port'])
 
     def test_call_proc(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.callproc('test_proc', ('beaker',))
 
-        assert(result)
+        self.assertTrue(result)
 
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "mysql")
         self.assertEqual(db_span.data["mysql"]["db"], testenv['mysql_db'])
@@ -185,24 +174,19 @@ def test_call_proc(self):
 
     def test_error_capture(self):
         result = None
-        span = None
         try:
             with tracer.start_active_span('test'):
                 result = self.cursor.execute("""SELECT * from blah""")
                 self.cursor.fetchone()
         except Exception:
             pass
-        finally:
-            if span:
-                span.finish()
 
-        assert(result is None)
+        self.assertIsNone(result)
 
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -227,8 +211,7 @@ def test_connect_cursor_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -253,8 +236,7 @@ def test_connect_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -279,8 +261,7 @@ def test_cursor_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)

tests/clients/test_psycopg2.py

@@ -64,8 +64,8 @@ def tearDown(self):
         return None
 
     def test_vanilla_query(self):
-        assert psycopg2.extras.register_uuid(None, self.db)
-        assert psycopg2.extras.register_uuid(None, self.db.cursor())
+        self.assertTrue(psycopg2.extras.register_uuid(None, self.db))
+        self.assertTrue(psycopg2.extras.register_uuid(None, self.db.cursor()))
 
         self.cursor.execute("""SELECT * from users""")
         result = self.cursor.fetchone()
@@ -84,14 +84,13 @@ def test_basic_query(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "postgres")
         self.assertEqual(db_span.data["pg"]["db"], testenv['postgresql_db'])
@@ -107,14 +106,13 @@ def test_basic_insert(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "postgres")
         self.assertEqual(db_span.data["pg"]["db"], testenv['postgresql_db'])
@@ -124,7 +122,6 @@ def test_basic_insert(self):
         self.assertEqual(db_span.data["pg"]["port"], testenv['postgresql_port'])
 
     def test_executemany(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.executemany("INSERT INTO users(name, email) VALUES(%s, %s)",
                                              [('beaker', 'beaker@muppets.com'), ('beaker', 'beaker@muppets.com')])
@@ -133,14 +130,13 @@ def test_executemany(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "postgres")
         self.assertEqual(db_span.data["pg"]["db"], testenv['postgresql_db'])
@@ -150,23 +146,21 @@ def test_executemany(self):
         self.assertEqual(db_span.data["pg"]["port"], testenv['postgresql_port'])
 
     def test_call_proc(self):
-        result = None
         with tracer.start_active_span('test'):
             result = self.cursor.callproc('test_proc', ('beaker',))
 
-        assert(type(result) is tuple)
+        self.assertIsInstance(result, tuple)
 
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
         self.assertEqual(db_span.p, test_span.s)
 
-        self.assertEqual(None, db_span.ec)
+        self.assertIsNone(db_span.ec)
 
         self.assertEqual(db_span.n, "postgres")
         self.assertEqual(db_span.data["pg"]["db"], testenv['postgresql_db'])
@@ -176,21 +170,19 @@ def test_call_proc(self):
         self.assertEqual(db_span.data["pg"]["port"], testenv['postgresql_port'])
 
     def test_error_capture(self):
-        result = None
         try:
             with tracer.start_active_span('test'):
                 result = self.cursor.execute("""SELECT * from blah""")
                 self.cursor.fetchone()
         except Exception:
             pass
 
-        assert(result is None)
+        self.assertIsNone(result)
 
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -257,8 +249,7 @@ def test_connect_cursor_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -282,8 +273,7 @@ def test_connect_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)
@@ -307,8 +297,7 @@ def test_cursor_ctx_mgr(self):
         spans = self.recorder.queued_spans()
         self.assertEqual(2, len(spans))
 
-        db_span = spans[0]
-        test_span = spans[1]
+        db_span, test_span = spans
 
         self.assertEqual("test", test_span.data["sdk"]["name"])
         self.assertEqual(test_span.t, db_span.t)