in ccadb2OneCRL/main.go [599:617]
func (u *Updater) UpdateRecordsWithBugID() transaction.Transactor {
return transaction.NewTransaction().WithCommit(func() error {
collection := StagingCollection()
for _, record := range u.changes {
if record == nil {
continue
}
err := u.staging.UpdateRecord(collection, record)
if err != nil {
return errors.WithStack(err)
}
}
return nil
}).WithRollback(func(_ error) error {
// Upstream transactions are going to delete these changes
// anyways, so I don't really see much of anything to do here.
return nil
})
}