(self)
| 134 | del self._txn |
| 135 | |
| 136 | def reset_state(self): |
| 137 | self._guard = DataFlowReentrantGuard() |
| 138 | super(LMDBData, self).reset_state() |
| 139 | self._open_lmdb() # open the LMDB in the worker process |
| 140 | |
| 141 | def __len__(self): |
| 142 | return self._size |
nothing calls this directly
no test coverage detected