Skip to content

Commit 78d75c5

Browse files
committed
handle unsupported error
1 parent 21533a4 commit 78d75c5

File tree

1 file changed

+30
-6
lines changed

1 file changed

+30
-6
lines changed

modules/migrations/migrate.go

Lines changed: 30 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,10 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
110110
log.Trace("migrating milestones")
111111
milestones, err := downloader.GetMilestones()
112112
if err != nil {
113-
return err
113+
if err != ErrNotSupported {
114+
return err
115+
}
116+
log.Warn("migrating milestones is not supported, ignored")
114117
}
115118

116119
msBatchSize := uploader.MaxBatchInsertSize("milestone")
@@ -130,7 +133,11 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
130133
log.Trace("migrating labels")
131134
labels, err := downloader.GetLabels()
132135
if err != nil {
133-
return err
136+
if err != ErrNotSupported {
137+
return err
138+
}
139+
140+
log.Warn("migrating labels is not supported, ignored")
134141
}
135142

136143
lbBatchSize := uploader.MaxBatchInsertSize("label")
@@ -150,7 +157,11 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
150157
log.Trace("migrating releases")
151158
releases, err := downloader.GetReleases()
152159
if err != nil {
153-
return err
160+
if err != ErrNotSupported {
161+
return err
162+
}
163+
164+
log.Warn("migrating releases is not supported, ignored")
154165
}
155166

156167
relBatchSize := uploader.MaxBatchInsertSize("release")
@@ -175,7 +186,12 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
175186
for i := 1; ; i++ {
176187
issues, isEnd, err := downloader.GetIssues(i, issueBatchSize)
177188
if err != nil {
178-
return err
189+
if err != ErrNotSupported {
190+
return err
191+
}
192+
193+
log.Warn("migrating issues is not supported, ignored")
194+
break
179195
}
180196

181197
if err := uploader.CreateIssues(issues...); err != nil {
@@ -190,7 +206,11 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
190206
for _, issue := range issues {
191207
comments, err := downloader.GetComments(issue.Number)
192208
if err != nil {
193-
return err
209+
if err != ErrNotSupported {
210+
return err
211+
}
212+
log.Warn("migrating comments is not supported, ignored")
213+
break
194214
}
195215

196216
allComments = append(allComments, comments...)
@@ -222,7 +242,11 @@ func migrateRepository(downloader base.Downloader, uploader base.Uploader, opts
222242
for i := 1; ; i++ {
223243
prs, err := downloader.GetPullRequests(i, prBatchSize)
224244
if err != nil {
225-
return err
245+
if err != ErrNotSupported {
246+
return err
247+
}
248+
log.Warn("migrating pull requests is not supported, ignored")
249+
break
226250
}
227251

228252
if err := uploader.CreatePullRequests(prs...); err != nil {

0 commit comments

Comments
 (0)