X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Fbindings%2Fpython%2Fbt2%2Fbt2%2Fquery_executor.py;h=17ddd97e86fd3d86563ad618266acf540637a1ce;hb=cfbd7cf3bde05e8a6606478889dcd663604ef7b5;hp=f0e984efc2ecc48b86e93d78423234026c4f836c;hpb=d24d56638469189904fb6ddbb3c725817b3e9417;p=babeltrace.git diff --git a/src/bindings/python/bt2/bt2/query_executor.py b/src/bindings/python/bt2/bt2/query_executor.py index f0e984ef..17ddd97e 100644 --- a/src/bindings/python/bt2/bt2/query_executor.py +++ b/src/bindings/python/bt2/bt2/query_executor.py @@ -40,17 +40,21 @@ class QueryExecutor(object._SharedObject): def cancel(self): status = native_bt.query_executor_cancel(self._ptr) - utils._handle_func_status(status, - 'cannot cancel query executor object') + utils._handle_func_status(status, 'cannot cancel query executor object') @property def is_canceled(self): is_canceled = native_bt.query_executor_is_canceled(self._ptr) - assert(is_canceled >= 0) + assert is_canceled >= 0 return is_canceled > 0 - def query(self, component_class, object, params=None, - logging_level=bt2.logging.LoggingLevel.NONE): + def query( + self, + component_class, + object, + params=None, + logging_level=bt2.logging.LoggingLevel.NONE, + ): if self.is_canceled: raise bt2.Canceled @@ -76,11 +80,11 @@ class QueryExecutor(object._SharedObject): params_ptr = params._ptr utils._check_log_level(logging_level) - cc_ptr = component_class._component_class_ptr() + cc_ptr = component_class._bt_component_class_ptr() - status, result_ptr = native_bt.query_executor_query(self._ptr, cc_ptr, - object, params_ptr, - logging_level) + status, result_ptr = native_bt.query_executor_query( + self._ptr, cc_ptr, object, params_ptr, logging_level + ) utils._handle_func_status(status, 'cannot query component class') - assert(result_ptr) + assert result_ptr return bt2.value._create_from_ptr(result_ptr)