Import topics during migration (#7851)

* add GetTopics interface

* CreateTopics

* remove un-needed comment
This commit is contained in:
Antoine GIRARD 2019-08-14 08:16:12 +02:00 committed by Lunny Xiao
parent 99a004c343
commit 46d6b92ad0
8 changed files with 34 additions and 0 deletions

View file

@ -82,6 +82,17 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
return err
}
log.Trace("migrating topics")
topics, err := downloader.GetTopics()
if err != nil {
return err
}
if len(topics) > 0 {
if err := uploader.CreateTopics(topics...); err != nil {
return err
}
}
if opts.Milestones {
log.Trace("migrating milestones")
milestones, err := downloader.GetMilestones()