lib: pass log level to bt_query_executor_query()
[babeltrace.git] / tests / bindings / python / bt2 / test_query_executor.py
index cdaccdcf087a7a5305aa1f865e5429a5a07e2436..4fc0f863760f13f372bea9454f6c251611d87f6e 100644 (file)
@@ -1,10 +1,9 @@
-from bt2 import values
+from bt2 import value
 import unittest
 import copy
 import bt2
 
 
-@unittest.skip("this is broken")
 class QueryExecutorTestCase(unittest.TestCase):
     def test_query(self):
         class MySink(bt2._UserSinkComponent):
@@ -12,7 +11,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 nonlocal query_params
                 query_params = params
                 return {
@@ -45,7 +44,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 nonlocal query_params
                 query_params = params
 
@@ -60,7 +59,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 raise ValueError
 
         with self.assertRaises(bt2.Error):
@@ -72,7 +71,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 raise bt2.InvalidQueryObject
 
         with self.assertRaises(bt2.InvalidQueryObject):
@@ -84,7 +83,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 raise bt2.InvalidQueryParams
 
         with self.assertRaises(bt2.InvalidQueryParams):
@@ -96,7 +95,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 raise bt2.TryAgain
 
         with self.assertRaises(bt2.TryAgain):
@@ -114,7 +113,7 @@ class QueryExecutorTestCase(unittest.TestCase):
                 pass
 
             @classmethod
-            def _query(cls, query_exec, obj, params):
+            def _query(cls, query_exec, obj, params, log_level):
                 raise bt2.TryAgain
 
         query_exec = bt2.QueryExecutor()
@@ -122,11 +121,3 @@ class QueryExecutorTestCase(unittest.TestCase):
 
         with self.assertRaises(bt2.QueryExecutorCanceled):
             res = query_exec.query(MySink, 'obj', [17, 23])
-
-    def test_eq(self):
-        query_exec = bt2.QueryExecutor()
-        self.assertEqual(query_exec, query_exec)
-
-    def test_eq_invalid(self):
-        query_exec = bt2.QueryExecutor()
-        self.assertNotEqual(query_exec, 23)
This page took 0.027482 seconds and 4 git commands to generate.