File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -172,9 +172,6 @@ impl SyncContext {
172
172
remote_encryption,
173
173
} ;
174
174
me. read_metadata ( ) . await ?;
175
- if me. durable_generation == 0 {
176
- return Err ( SyncError :: InvalidLocalState ( "generation is 0" . to_string ( ) ) . into ( ) ) ;
177
- }
178
175
Ok ( me)
179
176
}
180
177
@@ -575,6 +572,10 @@ impl SyncContext {
575
572
metadata
576
573
) ;
577
574
575
+ if metadata. generation == 0 {
576
+ return Err ( SyncError :: InvalidLocalState ( "generation is 0" . to_string ( ) ) . into ( ) ) ;
577
+ }
578
+
578
579
self . durable_generation = metadata. generation ;
579
580
self . durable_frame_num = metadata. durable_frame_num ;
580
581
@@ -991,7 +992,8 @@ pub async fn try_pull(
991
992
if !insert_handle. in_session ( ) {
992
993
tracing:: debug!(
993
994
"pull_frames: generation={}, frame={}, start wal transaction session" ,
994
- generation, next_frame_no
995
+ generation,
996
+ next_frame_no
995
997
) ;
996
998
insert_handle. begin ( ) ?;
997
999
}
You can’t perform that action at this time.
0 commit comments