Commit a record
(self)
| 163 | self.updated_shards.add(idx) |
| 164 | |
| 165 | def commit(self): |
| 166 | """Commit a record""" |
| 167 | if self.pending_nbytes != 0: |
| 168 | self._commit_internal(self.curr_data, self.curr_records) |
| 169 | self.curr_data = bytearray() |
| 170 | self.curr_records = [] |
| 171 | |
| 172 | def finish(self): |
| 173 | """Finish building and return shard records.""" |
no test coverage detected