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 {
172172 remote_encryption,
173173 } ;
174174 me. read_metadata ( ) . await ?;
175- if me. durable_generation == 0 {
176- return Err ( SyncError :: InvalidLocalState ( "generation is 0" . to_string ( ) ) . into ( ) ) ;
177- }
178175 Ok ( me)
179176 }
180177
@@ -575,6 +572,10 @@ impl SyncContext {
575572 metadata
576573 ) ;
577574
575+ if metadata. generation == 0 {
576+ return Err ( SyncError :: InvalidLocalState ( "generation is 0" . to_string ( ) ) . into ( ) ) ;
577+ }
578+
578579 self . durable_generation = metadata. generation ;
579580 self . durable_frame_num = metadata. durable_frame_num ;
580581
@@ -991,7 +992,8 @@ pub async fn try_pull(
991992 if !insert_handle. in_session ( ) {
992993 tracing:: debug!(
993994 "pull_frames: generation={}, frame={}, start wal transaction session" ,
994- generation, next_frame_no
995+ generation,
996+ next_frame_no
995997 ) ;
996998 insert_handle. begin ( ) ?;
997999 }
You can’t perform that action at this time.
0 commit comments