(self)
| 97 | |
| 98 | |
| 99 | def finalize_current_shard(self): |
| 100 | if self.shard_file is None: |
| 101 | # no-op if already finalized |
| 102 | return |
| 103 | self.shard_file.close() |
| 104 | self.shard_file = None |
| 105 | self.shard += 1 |
| 106 | self.con.commit() |
| 107 | |
| 108 | |
| 109 | def add(self, item): |
no outgoing calls
no test coverage detected