Fix bug: Cooldown interval config used instead of report interval (#158)

otterize · Nov 22, 2023 · cdd37bb · cdd37bb
1 parent ffe2aa9
commit cdd37bb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/kafka-watcher/pkg/logwatcher/filewatcher.go b/src/kafka-watcher/pkg/logwatcher/filewatcher.go
@@ -38,7 +38,7 @@ func (w *LogFileWatcher) RunForever(ctx context.Context) error {
 	go w.watchForever(ctx)
 
 	for {
-		time.Sleep(viper.GetDuration(config.KafkaCooldownIntervalKey))
+		time.Sleep(viper.GetDuration(config.KafkaReportIntervalKey))
 
 		if err := w.reportResults(ctx); err != nil {
 			logrus.WithError(err).Errorf("Failed reporting watcher results to mapper")

diff --git a/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go b/src/kafka-watcher/pkg/logwatcher/kubeneteslogwatcher.go
@@ -73,7 +73,7 @@ func (w *KubernetesLogWatcher) RunForever(ctx context.Context) error {
 	}
 
 	for {
-		time.Sleep(viper.GetDuration(config.KafkaCooldownIntervalKey))
+		time.Sleep(viper.GetDuration(config.KafkaReportIntervalKey))
 		if err := w.reportResults(ctx); err != nil {
 			logrus.WithError(err).Errorf("Failed reporting watcher results to mapper")
 		}