avoid endless loop

Signed-off-by: Florian Bacher <florian.bacher@dynatrace.com>
keptn · Sep 1, 2021 · 49b12dd · 49b12dd
1 parent bc956ef
commit 49b12dd
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/shipyard-controller/handler/sequence_migrator.go b/shipyard-controller/handler/sequence_migrator.go
@@ -55,11 +55,12 @@ func (sm *SequenceMigrator) MigrateSequences() {
 
 func (sm *SequenceMigrator) migrateSequencesOfProject(projectName string, wg *sync.WaitGroup) {
 	pageSize := int64(50)
-
+	nextPageKey := int64(0)
 	for {
 		rootEvents, err := sm.eventRepo.GetRootEvents(models.GetRootEventParams{
-			Project:  projectName,
-			PageSize: pageSize,
+			NextPageKey: nextPageKey,
+			Project:     projectName,
+			PageSize:    pageSize,
 		})
 		if err != nil {
 			log.WithError(err).Errorf("could not retrieve root events of project %s", projectName)
@@ -76,6 +77,7 @@ func (sm *SequenceMigrator) migrateSequencesOfProject(projectName string, wg *sy
 		if rootEvents.NextPageKey == 0 {
 			break
 		}
+		nextPageKey = rootEvents.NextPageKey
 	}
 	wg.Done()
 }