(self, writer_net, fields)
| 35 | self.schema = schema |
| 36 | |
| 37 | def write(self, writer_net, fields): |
| 38 | if isinstance(fields, Field): |
| 39 | fields = fields.field_blobs() |
| 40 | writer_net.CheckDatasetConsistency( |
| 41 | fields, [], fields=self.schema.field_names()) |
| 42 | status = writer_net.NextName() |
| 43 | writer_net.SafeEnqueueBlobs( |
| 44 | [self.blobs_queue] + fields, fields + [status]) |
| 45 | return status |
| 46 | |
| 47 | |
| 48 | class RecordQueue: |
no test coverage detected