File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -102,7 +102,8 @@ def rewind(self):
102
102
return True
103
103
104
104
def stream_changes (self , stop_version = None , offset = None ) -> Iterator [Change ]:
105
- if not stop_version and self .read_metadata ():
105
+ if stop_version is None :
106
+ self .read_metadata ()
106
107
stop_version = self .version
107
108
108
109
offset = 512 if offset is None else offset
@@ -187,12 +188,12 @@ def _compact_async(self, clone):
187
188
if self .stop_compact :
188
189
return clone .cleanup ()
189
190
190
- if change .version == stop_ver :
191
- break
192
-
193
191
if change .snapshot is not None :
194
192
self ._restore_snapshot (change .snapshot , snapshotpath )
195
193
194
+ if change .version == stop_ver :
195
+ break
196
+
196
197
if change .transaction is not None :
197
198
self ._restore_transaction (change .transaction )
198
199
self .db .commit ()
You can’t perform that action at this time.
0 commit comments