lib: remove unused _NO_SINK graph status

[babeltrace.git] / tests / bindings / python / bt2 / test_graph.py

diff --git a/tests/bindings/python/bt2/test_graph.py b/tests/bindings/python/bt2/test_graph.py
index 6d8bf59023b273bbfbaa7772cb0c760af9c76952..73788b48001f3b31dd2b3ce00171a7269fa2153e 100644 (file)
--- a/tests/bindings/python/bt2/test_graph.py
+++ b/tests/bindings/python/bt2/test_graph.py
@@ -1,4 +1,4 @@
-from bt2 import values
+from bt2 import value
 import collections
 import unittest
 import copy
@@ -240,10 +240,10 @@ class GraphTestCase(unittest.TestCase):
                 self._trace = bt2.Trace()
                 self._sc = bt2.StreamClass()
                 self._ec = bt2.EventClass('salut')
-                self._my_int_ft = bt2.IntegerFieldType(32)
-                self._ec.payload_field_type = bt2.StructureFieldType()
-                self._ec.payload_field_type += collections.OrderedDict([
-                    ('my_int', self._my_int_ft),
+                self._my_int_fc = bt2.IntegerFieldClass(32)
+                self._ec.payload_field_class = bt2.StructureFieldClass()
+                self._ec.payload_field_class += collections.OrderedDict([
+                    ('my_int', self._my_int_fc),
                 ])
                 self._sc.add_event_class(self._ec)
                 self._trace.add_stream_class(self._sc)
@@ -312,10 +312,10 @@ class GraphTestCase(unittest.TestCase):
                 self._trace = bt2.Trace()
                 self._sc = bt2.StreamClass()
                 self._ec = bt2.EventClass('salut')
-                self._my_int_ft = bt2.IntegerFieldType(32)
-                self._ec.payload_field_type = bt2.StructureFieldType()
-                self._ec.payload_field_type += collections.OrderedDict([
-                    ('my_int', self._my_int_ft),
+                self._my_int_fc = bt2.IntegerFieldClass(32)
+                self._ec.payload_field_class = bt2.StructureFieldClass()
+                self._ec.payload_field_class += collections.OrderedDict([
+                    ('my_int', self._my_int_fc),
                 ])
                 self._sc.add_event_class(self._ec)
                 self._trace.add_stream_class(self._sc)
@@ -370,29 +370,6 @@ class GraphTestCase(unittest.TestCase):
         with self.assertRaises(bt2.TryAgain):
             self._graph.run()
 
-    def test_run_no_sink(self):
-        class MyIter(bt2._UserMessageIterator):
-            pass
-
-        class MySource(bt2._UserSourceComponent,
-                       message_iterator_class=MyIter):
-            def __init__(self, params):
-                self._add_output_port('out')
-
-        class MyFilter(bt2._UserFilterComponent,
-                       message_iterator_class=MyIter):
-            def __init__(self, params):
-                self._add_output_port('out')
-                self._add_input_port('in')
-
-        src = self._graph.add_component(MySource, 'src')
-        flt = self._graph.add_component(MyFilter, 'flt')
-        conn = self._graph.connect_ports(src.output_ports['out'],
-                                         flt.input_ports['in'])
-
-        with self.assertRaises(bt2.NoSinkComponent):
-            self._graph.run()
-
     def test_run_error(self):
         class MyIter(bt2._UserMessageIterator):
             def __init__(self):
@@ -403,10 +380,10 @@ class GraphTestCase(unittest.TestCase):
                 self._trace = bt2.Trace()
                 self._sc = bt2.StreamClass()
                 self._ec = bt2.EventClass('salut')
-                self._my_int_ft = bt2.IntegerFieldType(32)
-                self._ec.payload_field_type = bt2.StructureFieldType()
-                self._ec.payload_field_type += collections.OrderedDict([
-                    ('my_int', self._my_int_ft),
+                self._my_int_fc = bt2.IntegerFieldClass(32)
+                self._ec.payload_field_class = bt2.StructureFieldClass()
+                self._ec.payload_field_class += collections.OrderedDict([
+                    ('my_int', self._my_int_fc),
                 ])
                 self._sc.add_event_class(self._ec)
                 self._trace.add_stream_class(self._sc)