this repo has no description
fix small bugs in resync
+7
-5
+7
-5
nexus/resync.go
+7
-5
nexus/resync.go
···
202
202
n.logger.Error("failed to flush batch", "error", err, "did", did)
203
203
return err
204
204
}
205
+
evtBatch = evtBatch[:0]
205
206
}
206
-
evtBatch = evtBatch[:0]
207
207
208
208
return nil
209
209
})
···
219
219
if err := n.db.Model(&models.Repo{}).
220
220
Where("did = ?", did).
221
221
Updates(map[string]interface{}{
222
-
"state": models.RepoStateActive,
223
-
"rev": rev,
224
-
"prev_data": commit.Data.String(),
225
-
"error_msg": "",
222
+
"state": models.RepoStateActive,
223
+
"rev": rev,
224
+
"prev_data": commit.Data.String(),
225
+
"error_msg": "",
226
+
"retry_count": 0,
227
+
"retry_after": 0,
226
228
}).Error; err != nil {
227
229
return false, fmt.Errorf("failed to update repo state to active %w", err)
228
230
}