interrupter = query_exec.default_interrupter
self.assertIs(type(interrupter), bt2.Interrupter)
interrupter = query_exec.default_interrupter
self.assertIs(type(interrupter), bt2.Interrupter)
def _user_query(cls, priv_query_exec, obj, params, method_obj):
nonlocal query_params
query_params = params
def _user_query(cls, priv_query_exec, obj, params, method_obj):
nonlocal query_params
query_params = params
- 'array': ['coucou', 23, None],
- 'other_map': {'yes': 'yeah', '19': 19, 'minus 1.5': -1.5},
- 'null': None,
+ "array": ["coucou", 23, None],
+ "other_map": {"yes": "yeah", "19": 19, "minus 1.5": -1.5},
+ "null": None,
- method_obj.hola = 'hello'
- query_exec = bt2.QueryExecutor(MySink, 'obj', method_obj=method_obj)
+ method_obj.hola = "hello"
+ query_exec = bt2.QueryExecutor(MySink, "obj", method_obj=method_obj)
query_exec.logging_level = bt2.LoggingLevel.INFO
query_exec.query()
self.assertEqual(query_log_level, bt2.LoggingLevel.INFO)
query_exec.logging_level = bt2.LoggingLevel.INFO
query_exec.query()
self.assertEqual(query_log_level, bt2.LoggingLevel.INFO)
- bt2.QueryExecutor(MySink, 'obj', [17, 23]).query()
+ bt2.QueryExecutor(MySink, "obj", [17, 23]).query()
exc = ctx.exception
self.assertEqual(len(exc), 3)
cause = exc[0]
self.assertIsInstance(cause, bt2._ComponentClassErrorCause)
exc = ctx.exception
self.assertEqual(len(exc), 3)
cause = exc[0]
self.assertIsInstance(cause, bt2._ComponentClassErrorCause)
- bt2.QueryExecutor(MySink, 'obj', [17, 23]).query()
+ bt2.QueryExecutor(MySink, "obj", [17, 23]).query()
def _user_query(cls, priv_query_exec, obj, params, method_obj):
pass
def _user_query(cls, priv_query_exec, obj, params, method_obj):
pass
- query_exec = bt2.QueryExecutor(MySink, 'obj', [17, 23])
+ query_exec = bt2.QueryExecutor(MySink, "obj", [17, 23])
def _user_query(cls, priv_query_exec, obj, params, method_obj):
pass
def _user_query(cls, priv_query_exec, obj, params, method_obj):
pass
- query_exec = bt2.QueryExecutor(MySink, 'obj', [17, 23])
+ query_exec = bt2.QueryExecutor(MySink, "obj", [17, 23])
- bt2.QueryExecutor(MySink, 'obj', [17, 23]).query()
+ bt2.QueryExecutor(MySink, "obj", [17, 23]).query()
- query_exec = bt2.QueryExecutor(MySink, 'obj', [17, 23])
+ query_exec = bt2.QueryExecutor(MySink, "obj", [17, 23])
- query_exec = bt2.QueryExecutor(MySink, 'obj', [17, 23])
+ query_exec = bt2.QueryExecutor(MySink, "obj", [17, 23])
- query_exec = bt2.QueryExecutor(MySink, 'obj', [17, 23])
+ query_exec = bt2.QueryExecutor(MySink, "obj", [17, 23])