diff --git a/cmd/integration/commands/stages.go b/cmd/integration/commands/stages.go index 8beb0ce903c..a5af093301d 100644 --- a/cmd/integration/commands/stages.go +++ b/cmd/integration/commands/stages.go @@ -561,7 +561,7 @@ func stageSnapshots(db kv.TemporalRwDB, ctx context.Context, logger log.Logger) } } logger.Info("Progress", "snapshots", progress) - return nil + return tx.Commit() } func stageHeaders(db kv.TemporalRwDB, ctx context.Context, logger log.Logger) error {