new strategy

ydb-platform · Aug 15, 2024 · 7b5cae2 · 7b5cae2
1 parent cc5a789
commit 7b5cae2
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/slo/src/Internal/SloContext.cs b/slo/src/Internal/SloContext.cs
@@ -125,8 +125,8 @@ public async Task Run(RunConfig runConfig)
 
         var errorsGauge = metricFactory.CreateGauge("errors", "amount of errors", new[] { "class", "in" });
 
-        var writeLimiter = Policy.RateLimit(runConfig.WriteRps, TimeSpan.FromSeconds(1), runConfig.WriteRps);
-        var readLimiter = Policy.RateLimit(runConfig.ReadRps, TimeSpan.FromSeconds(1), runConfig.ReadRps);
+        var writeLimiter = Policy.RateLimit(runConfig.WriteRps, TimeSpan.FromSeconds(1), 10);
+        var readLimiter = Policy.RateLimit(runConfig.ReadRps, TimeSpan.FromSeconds(1), 10);
 
         var cancellationTokenSource = new CancellationTokenSource();
         cancellationTokenSource.CancelAfter(TimeSpan.FromSeconds(runConfig.ShutdownTime));
@@ -189,7 +189,7 @@ Task ShootingTask(RateLimitPolicy rateLimitPolicy, string shootingName,
                         _logger.LogInformation(e, "Waiting {ShootingName} task, count active tasks: {}", shootingName,
                             Interlocked.Read(ref activeTasks));
 
-                        await Task.Delay(990, cancellationTokenSource.Token);
+                        await Task.Delay(e.RetryAfter, cancellationTokenSource.Token);
                     }
                 }