projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
lib: remove `BT_GRAPH_RUN_STATUS_END`
[babeltrace.git]
/
src
/
bindings
/
python
/
bt2
/
bt2
/
graph.py
diff --git
a/src/bindings/python/bt2/bt2/graph.py
b/src/bindings/python/bt2/bt2/graph.py
index 82708025c19032b91c72b063d977567b95ca4995..a36c85d1b7176cb37626aa1976775a40ec8454b8 100644
(file)
--- a/
src/bindings/python/bt2/bt2/graph.py
+++ b/
src/bindings/python/bt2/bt2/graph.py
@@
-129,7
+129,11
@@
class Graph(object._SharedObject):
if obj is not None and not native_bt.bt2_is_python_component_class(base_cc_ptr):
raise ValueError('cannot pass a Python object to a non-Python component')
if obj is not None and not native_bt.bt2_is_python_component_class(base_cc_ptr):
raise ValueError('cannot pass a Python object to a non-Python component')
+ if params is not None and not isinstance(params, (dict, bt2.MapValue)):
+ raise TypeError("'params' parameter is not a 'dict' or a 'bt2.MapValue'.")
+
params = bt2.create_value(params)
params = bt2.create_value(params)
+
params_ptr = params._ptr if params is not None else None
status, comp_ptr = add_fn(
params_ptr = params._ptr if params is not None else None
status, comp_ptr = add_fn(
@@
-185,14
+189,7
@@
class Graph(object._SharedObject):
def run(self):
status = native_bt.graph_run(self._ptr)
def run(self):
status = native_bt.graph_run(self._ptr)
-
- try:
- utils._handle_func_status(status, 'graph object stopped running')
- except bt2.Stop:
- # done
- return
- except Exception:
- raise
+ utils._handle_func_status(status, 'graph object stopped running')
def add_interrupter(self, interrupter):
utils._check_type(interrupter, bt2_interrupter.Interrupter)
def add_interrupter(self, interrupter):
utils._check_type(interrupter, bt2_interrupter.Interrupter)
This page took
0.025136 seconds
and
4
git commands to generate.