self._in = self._add_input_port('in')
def _user_graph_is_configured(self):
- self._iter = self._create_input_port_message_iterator(self._in)
+ self._iter = self._create_message_iterator(self._in)
def _user_consume(self):
next(self._iter)
self._in = self._add_input_port('in')
def _user_graph_is_configured(self):
- self._iter = self._create_input_port_message_iterator(self._in)
+ self._iter = self._create_message_iterator(self._in)
def _user_consume(self):
try:
# expected bits.
exc = self._run_failing_graph(SourceWithFailingIter, SinkWithExceptionChaining)
s = str(exc)
- self.assertIn('[src (out): src.SourceWithFailingIter]', s)
+ self.assertIn("[src (out): 'source.SourceWithFailingIter']", s)
self.assertIn('ValueError: oops', s)