fix:correct 'RunTicker' method

aws-solutions · Dec 20, 2022 · 0c7ec75 · 0c7ec75
1 parent 611b5c9
commit 0c7ec75
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()
 	}
 }