Update periodicalexecutor.go (#389)

4 years ago · c77b8489d7
parent eca4ed2cc0
commit c77b8489d7
1 changed files with 1 additions and 1 deletions
--- a/core/executors/periodicalexecutor.go
+++ b/core/executors/periodicalexecutor.go
@ -51,7 +51,7 @@ func NewPeriodicalExecutor(interval time.Duration, container TaskContainer) *Per
 		container:   container,
 		confirmChan: make(chan lang.PlaceholderType),
 		newTicker: func(d time.Duration) timex.Ticker {
-			return timex.NewTicker(interval)
+			return timex.NewTicker(d)
 		},
 	}
 	proc.AddShutdownListener(func() {