feat: fix duration logic for the flag

Trendyol · Jul 5, 2024 · d46441e · d46441e
1 parent 4c33550
commit d46441e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/cron.go b/internal/cron.go
@@ -87,5 +87,7 @@ func (s *cronsumer) startConsume(cfg kafka.ConsumerConfig) {
 
 	go s.consumer.Listen(ctx, cfg.BackOffStrategy.String(), &cancelFuncWrapper)
 
-	time.AfterFunc(cfg.Duration, cancelFuncWrapper)
+	if !cfg.DisableExceptionCron {
+		time.AfterFunc(cfg.Duration, cancelFuncWrapper)
+	}
 }