(self, local_init_net, local_finish_net)
| 26 | exit_net.CloseBlobsQueue([self._wrapper.queue()], 0) |
| 27 | |
| 28 | def read_ex(self, local_init_net, local_finish_net): |
| 29 | self._wrapper._new_reader(local_init_net) |
| 30 | dequeue_net = core.Net('dequeue') |
| 31 | fields, status_blob = dequeue( |
| 32 | dequeue_net, |
| 33 | self._wrapper.queue(), |
| 34 | len(self.schema().field_names()), |
| 35 | field_names=self.schema().field_names(), |
| 36 | num_records=self._num_dequeue_records) |
| 37 | return [dequeue_net], status_blob, fields |
| 38 | |
| 39 | def read(self, net): |
| 40 | net, _, fields = self.read_ex(net, None) |
no test coverage detected