Merge pull request #11 from aws-samples/develop

fix:correct 'RunTicker' method
aws-solutions · Dec 21, 2022 · 49f8b14 · 49f8b14
2 parents 611b5c9 + 0c7ec75
commit 49f8b14
Showing 1 changed file with 4 additions and 9 deletions.
diff --git a/dth/job.go b/dth/job.go
@@ -137,15 +137,10 @@ func RunTicker(ctx context.Context, cfg *JobConfig) {
 	t := &JobTicker{}
 	t.updateTimer()
 	for {
-		select {
-		case <-ctx.Done():
-			log.Printf("timer has been stopped")
-			t.timer.Stop()
-		case <-t.timer.C:
-			log.Printf("ticker update S3 Credentials")
-			updateCreds(ctx, cfg)
-			t.updateTimer()
-		}
+		<-t.timer.C
+		log.Printf("ticker update S3 Credentials")
+		updateCreds(ctx, cfg)
+		t.updateTimer()
 	}
 }