hot fix

Author: LiamHamsters

src/Ydb.Sdk/src/Ado/BulkUpsert/BulkUpsertFormat.cs

@@ -2,6 +2,6 @@ namespace Ydb.Sdk.Ado.BulkUpsert;
 
 public enum BulkUpsertFormat
 {
-    Proto = 0,
+    Proto = 0
     // Arrow = 1
 }

src/Ydb.Sdk/src/Ado/BulkUpsert/YdbBulkUpsertProtoImporter.cs

@@ -94,14 +94,15 @@ await _connection.BulkUpsertProtoAsync(
     private Type GetStructType()
     {
         var structType = new Type { StructType = new StructType() };
-        for (int i = 0; i < _columns.Count; i++)
+        for (var i = 0; i < _columns.Count; i++)
         {
             structType.StructType.Members.Add(new StructMember
             {
                 Name = _columns[i],
                 Type = _types[i]
             });
         }
+
         return structType;
     }
 

src/Ydb.Sdk/src/Ado/YdbConnection.cs

@@ -101,7 +101,7 @@ public async Task BulkUpsertAsync(
             throw YdbException.FromServer(operation.Status, operation.Issues);
         }
     }
-    
+
     public async Task BulkUpsertProtoAsync(
         string tablePath,
         Type structType,
@@ -118,7 +118,7 @@ public async Task BulkUpsertProtoAsync(
         var typedValue = new TypedValue { Type = structType, Value = listValue };
         var req = new BulkUpsertRequest { Table = tablePath, Rows = typedValue };
 
-        int attempt = 0;
+        var attempt = 0;
         while (true)
         {
             try

src/Ydb.Sdk/test/Ydb.Sdk.Ado.Tests/YdbConnectionTests.cs

@@ -538,7 +538,7 @@ PRIMARY KEY (Id)
             new Type { TypeId = Type.Types.PrimitiveTypeId.Utf8 }
         };
 
-        await using (var importer = new YdbBulkUpsertProtoImporter(conn, absTablePath, columns, types, maxBytes: 250))
+        await using (var importer = new YdbBulkUpsertProtoImporter(conn, absTablePath, columns, types, maxBytes: 30))
         {
             await importer.AddRowAsync(
                 YdbValue.MakeInt32(1), YdbValue.MakeUtf8("A"));
@@ -547,8 +547,6 @@ await importer.AddRowAsync(
             await importer.AddRowAsync(
                 YdbValue.MakeInt32(3), YdbValue.MakeUtf8("C"));
 
-            await importer.DisposeAsync();
-
             Assert.Empty(importer.GetBufferedRows());
         }