feat: update default rate limits

Signed-off-by: Soumya Ghosh Dastidar <gdsoumya@gmail.com>
argoproj · Sep 15, 2023 · e57757c · e57757c
1 parent 573a709
commit e57757c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/ratelimiter/ratelimiter.go b/pkg/ratelimiter/ratelimiter.go
@@ -24,10 +24,10 @@ func GetAppRateLimiterConfig() *AppControllerRateLimiterConfig {
 		int(env.ParseInt64FromEnv("WORKQUEUE_BUCKET_SIZE", 500, 1, math.MaxInt64)),
 		int(env.ParseInt64FromEnv("WORKQUEUE_BUCKET_QPS", 50, 1, math.MaxInt64)),
 		// individual item rate limit config
-		// when WORKQUEUE_FAILURE_COOLDOWN is 0 per item rate limiting default disabled(default)
-		time.Duration(env.ParseInt64FromEnv("WORKQUEUE_FAILURE_COOLDOWN_NS", 0, 0, (24 * time.Hour).Nanoseconds())),
+		// when WORKQUEUE_FAILURE_COOLDOWN is 0 per item rate limiting is disabled
+		time.Duration(env.ParseInt64FromEnv("WORKQUEUE_FAILURE_COOLDOWN_NS", time.Minute.Nanoseconds(), 0, (24 * time.Hour).Nanoseconds())),
 		time.Duration(env.ParseInt64FromEnv("WORKQUEUE_BASE_DELAY_NS", 1000, 1, (24 * time.Hour).Nanoseconds())),
-		time.Duration(env.ParseInt64FromEnv("WORKQUEUE_MAX_DELAY_NS", (120 * time.Second).Nanoseconds(), 1*time.Millisecond.Nanoseconds(), (24 * time.Hour).Nanoseconds())),
+		time.Duration(env.ParseInt64FromEnv("WORKQUEUE_MAX_DELAY_NS", (3 * time.Second).Nanoseconds(), 1*time.Millisecond.Nanoseconds(), (24 * time.Hour).Nanoseconds())),
 	}
 }