Merge remote-tracking branch 'origin/main' into andy/safe-format

This commit is contained in:
Andy Arthur
2022-08-10 15:07:48 -07:00
6 changed files with 47 additions and 6 deletions
@@ -169,6 +169,9 @@ func migrateCommit(ctx context.Context, oldCm *doltdb.Commit, new *doltdb.DoltDB
if err = new.SetHead(ctx, flushRef, newHash); err != nil {
return err
}
if err = new.ShallowGC(ctx); err != nil {
return err
}
// validate root after we flush the ChunkStore to facilitate
// investigating failed migrations
@@ -135,18 +135,18 @@ func (s *prollyWriteSession) flush(ctx context.Context) (*doltdb.WorkingSet, err
tables := make(map[string]*doltdb.Table, len(s.tables))
mu := &sync.Mutex{}
eg, ctx := errgroup.WithContext(ctx)
eg, ctx2 := errgroup.WithContext(ctx)
for n := range s.tables {
name := n // make a copy
eg.Go(func() error {
wr := s.tables[name]
t, err := wr.table(ctx)
t, err := wr.table(ctx2)
if err != nil {
return err
}
if schema.HasAutoIncrement(wr.sch) {
t, err = t.SetAutoIncrementValue(ctx, s.tracker.Current(name))
t, err = t.SetAutoIncrementValue(ctx2, s.tracker.Current(name))
if err != nil {
return err
}