Skip to content

Commit ff0b3eb

Browse files
agneumNikolayS
authored andcommitted
fix: issue a checkpoint after successful execution of query preprocessing scripts
1 parent 8685499 commit ff0b3eb

File tree

1 file changed

+4
-0
lines changed
  • engine/internal/retrieval/engine/postgres/snapshot

1 file changed

+4
-0
lines changed

engine/internal/retrieval/engine/postgres/snapshot/logical.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -263,6 +263,10 @@ func (s *LogicalInitial) runPreprocessingQueries(ctx context.Context, dataDir st
263263
return errors.Wrap(err, "failed to run preprocessing queries")
264264
}
265265

266+
if err := tools.RunCheckpoint(ctx, s.dockerClient, containerID, s.globalCfg.Database.User(), s.globalCfg.Database.Name()); err != nil {
267+
return errors.Wrap(err, "failed to run checkpoint before stop")
268+
}
269+
266270
return nil
267271
}
268272

0 commit comments

Comments
 (0)