fix linter

Author: KirillKurdyukov

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Stress.Loader/Cli.cs

@@ -9,7 +9,7 @@ public static class Cli
         "connectionString",
         "YDB connection string ADO NET format"
     );
-    
+
     private static readonly Option<int> PeakRps = new("--peak-rps", () => 1000,
         "Peak RPS load (top of the step)");
 
@@ -19,16 +19,16 @@ public static class Cli
     private static readonly Option<int> MinRps = new("--min-rps", () => 1,
         "Minimum RPS load (bottom of the step, 1-2 RPS)");
 
-    private static readonly Option<int> PeakDurationSeconds = new("--peak-duration", () => 60,
+    private static readonly Option<int> PeakDurationSeconds = new("--peak-duration", () => 600,
         "Duration of peak load in seconds");
 
-    private static readonly Option<int> MediumDurationSeconds = new("--medium-duration", () => 30,
+    private static readonly Option<int> MediumDurationSeconds = new("--medium-duration", () => 1800,
         "Duration of medium load in seconds");
 
-    private static readonly Option<int> MinDurationSeconds = new("--min-duration", () => 30,
+    private static readonly Option<int> MinDurationSeconds = new("--min-duration", () => 1800,
         "Duration of minimum load in seconds");
 
-    private static readonly Option<int> TotalTestTimeSeconds = new("--total-time", () => 600,
+    private static readonly Option<int> TotalTestTimeSeconds = new("--total-time", () => 14400,
         "Total test duration in seconds");
 
     private static readonly Option<string?> SaFilePath = new("--sa-file-path",

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Stress.Loader/StressTestTank.cs

@@ -18,7 +18,6 @@ public StressTestTank(StressTestConfig config)
         _logger = loggerFactory.CreateLogger<StressTestTank>();
         _settings = new YdbConnectionStringBuilder(config.ConnectionString)
         {
-            LoggerFactory = loggerFactory,
             CredentialsProvider =
                 config.SaFilePath != null ? new ServiceAccountProvider(config.SaFilePath, loggerFactory) : null
         };
@@ -67,22 +66,19 @@ Starting YDB ADO.NET Stress Test Tank
     private async Task RunLoadPatternAsync(LoadPattern loadPattern, CancellationToken cancellationToken)
     {
         var currentRpsSource = new CancellationTokenSource();
-        var workerTasks = new List<Task>();
-
-        // Start background task to update RPS based on load pattern
         var rpsControllerTask = Task.Run(async () =>
         {
+            // ReSharper disable once PossiblyMistakenUseOfCancellationToken
             await foreach (var targetRps in loadPattern.GetLoadStepsAsync(cancellationToken))
             {
                 await currentRpsSource.CancelAsync();
-                await Task.WhenAll(workerTasks);
-                workerTasks.Clear();
 
                 currentRpsSource = new CancellationTokenSource();
                 var combinedToken = CancellationTokenSource
                     .CreateLinkedTokenSource(cancellationToken, currentRpsSource.Token).Token;
-                await StartWorkersForRpsAsync(targetRps, workerTasks, combinedToken);
+                _ = StartWorkersForRpsAsync(targetRps, combinedToken);
             }
+            // ReSharper disable once PossiblyMistakenUseOfCancellationToken
         }, cancellationToken);
 
         try
@@ -92,12 +88,10 @@ private async Task RunLoadPatternAsync(LoadPattern loadPattern, CancellationToke
         finally
         {
             await currentRpsSource.CancelAsync();
-            await Task.WhenAll(workerTasks);
         }
     }
 
-    private async Task StartWorkersForRpsAsync(int targetRps, List<Task> workerTasks,
-        CancellationToken cancellationToken)
+    private async Task StartWorkersForRpsAsync(int targetRps, CancellationToken cancellationToken)
     {
         if (targetRps <= 0) return;
 
@@ -120,22 +114,25 @@ private async Task StartWorkersForRpsAsync(int targetRps, List<Task> workerTasks
                 continue;
             }
 
-            workerTasks.Add(
-                Task.Run(async () =>
+            _ = Task.Run(async () =>
+            {
+                try
                 {
-                    try
-                    {
-                        await using var ydbConnection = new YdbConnection(_settings);
-                        await ydbConnection.OpenAsync(cancellationToken);
-                        await new YdbCommand(ydbConnection) { CommandText = _config.TestQuery }
-                            .ExecuteNonQueryAsync(cancellationToken);
-                    }
-                    catch (Exception e)
+                    await using var ydbConnection = new YdbConnection(_settings);
+                    await ydbConnection.OpenAsync(cancellationToken);
+                    await new YdbCommand(ydbConnection) { CommandText = _config.TestQuery }
+                        .ExecuteNonQueryAsync(cancellationToken);
+                }
+                catch (YdbException e)
+                {
+                    if (e.Code == StatusCode.ClientTransportTimeout)
                     {
-                        _logger.LogError(e, "Fail operation");
+                        return;
                     }
-                }, cancellationToken)
-            );
+
+                    _logger.LogError(e, "Fail operation");
+                }
+            }, cancellationToken);
         }
     }