fix write graphs

Author: poma12390

slo/src/Linq2db.Slo/SloLinq2DbContext.cs

@@ -1,4 +1,6 @@
-using LinqToDB;
+using System;
+using System.Threading.Tasks;
+using LinqToDB;
 using LinqToDB.Data;
 using LinqToDB.Mapping;
 using Internal;
@@ -18,22 +20,16 @@ static SloTableContext()
             maxAttempts: 10,
             onRetry: (attempt, ex, delay) =>
             {
-                // здесь при желании снимать метрики: attempt, delay, ((YdbException)ex).Code
+                // метрики/логи при желании
             }
         );
     }
 
     public sealed class Linq2dbClient
     {
         private readonly string _connectionString;
-
-        public Linq2dbClient(string connectionString)
-        {
-            _connectionString = connectionString;
-        }
-
-        public DataConnection Open()
-            => new DataConnection("YDB", _connectionString);
+        public Linq2dbClient(string connectionString) => _connectionString = connectionString;
+        public DataConnection Open() => new DataConnection("YDB", _connectionString);
     }
 
     protected override Linq2dbClient CreateClient(Config config)
@@ -58,15 +54,14 @@ PRIMARY KEY (Guid, Id)
         }
         catch
         {
-            // YDB не поддерживает IF NOT EXISTS; если таблица есть — окей
+            // YDB не поддерживает IF NOT EXISTS; если таблица есть — это норм
         }
 
         if (!string.IsNullOrWhiteSpace(SloTable.Options))
-        {
             await db.ExecuteAsync(SloTable.Options);
-        }
     }
 
+    // ВАЖНО: вернуть >0 при успехе, иначе write-графики будут пустые.
     protected override async Task<int> Save(Linq2dbClient client, SloTable sloTable, int writeTimeout)
     {
         await using var db = client.Open();
@@ -77,7 +72,7 @@ await db.ExecuteAsync($@"
 VALUES ({sloTable.Guid}, {sloTable.Id}, {sloTable.PayloadStr}, {sloTable.PayloadDouble}, {sloTable.PayloadTimestamp});
 ");
 
-        return 0;
+        return 1;
     }
 
     protected override async Task<object?> Select(Linq2dbClient client, (Guid Guid, int Id) select, int readTimeout)

src/Linq2db.Ydb/src/Internal/YdbSdkRetryPolicyAdapter.cs

@@ -1,7 +1,6 @@
-// для DataConnection в Factory
-using L2RetryOptions = LinqToDB.Data.RetryPolicy.RetryPolicyOptions;
+using L2RetryOptions = LinqToDB.Data.RetryPolicy.RetryPolicyOptions;
 using L2IRetryPolicy = LinqToDB.Data.RetryPolicy.IRetryPolicy;
-using Ydb.Sdk.Ado;
+using Ydb.Sdk.Ado; // <== важно: тут YdbException
 using Ydb.Sdk.Ado.RetryPolicy;
 
 namespace LinqToDB.Internal.DataProvider.Ydb.Internal
@@ -127,10 +126,6 @@ private static bool TryFindYdbException(Exception ex, out YdbException ydbEx)
     /// </summary>
     public static class YdbSdkRetryPolicyRegistration
     {
-        /// <summary>
-        /// Подключить ретраи SDK глобально для всех новых DataConnection.
-        /// Вызывать один раз при старте/перед SLO-тестом.
-        /// </summary>
         public static void UseGlobally(YdbRetryPolicyConfig? config = null, Action<int, Exception, TimeSpan?>? onRetry = null)
         {
             L2RetryOptions.Default = L2RetryOptions.Default with
@@ -151,11 +146,11 @@ public static void UseGloballyWithIdempotence(
             var cfg = new YdbRetryPolicyConfig
             {
                 EnableRetryIdempotence = true,
-                MaxAttempts      = maxAttempts   ?? YdbRetryPolicyConfig.Default.MaxAttempts,
-                FastBackoffBaseMs = fastBaseMs   ?? YdbRetryPolicyConfig.Default.FastBackoffBaseMs,
-                SlowBackoffBaseMs = slowBaseMs   ?? YdbRetryPolicyConfig.Default.SlowBackoffBaseMs,
-                FastCapBackoffMs  = fastCapMs    ?? YdbRetryPolicyConfig.Default.FastCapBackoffMs,
-                SlowCapBackoffMs  = slowCapMs    ?? YdbRetryPolicyConfig.Default.SlowCapBackoffMs
+                MaxAttempts       = maxAttempts   ?? YdbRetryPolicyConfig.Default.MaxAttempts,
+                FastBackoffBaseMs = fastBaseMs    ?? YdbRetryPolicyConfig.Default.FastBackoffBaseMs,
+                SlowBackoffBaseMs = slowBaseMs    ?? YdbRetryPolicyConfig.Default.SlowBackoffBaseMs,
+                FastCapBackoffMs  = fastCapMs     ?? YdbRetryPolicyConfig.Default.FastCapBackoffMs,
+                SlowCapBackoffMs  = slowCapMs     ?? YdbRetryPolicyConfig.Default.SlowCapBackoffMs
             };
 
             UseGlobally(cfg, onRetry);