test

Author: LiamHamsters

src/Ydb.Sdk/src/Ado/YdbCommand.cs

@@ -3,7 +3,6 @@
 using System.Diagnostics.CodeAnalysis;
 using System.Text;
 using Ydb.Sdk.Ado.Internal;
-using Ydb.Sdk.Ado.Session;
 
 namespace Ydb.Sdk.Ado;
 

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

@@ -100,7 +100,7 @@ public override async Task OpenAsync(CancellationToken cancellationToken)
 
         ConnectionState = ConnectionState.Open;
     }
-    
+
     internal async ValueTask OpenAsync(
         YdbRetryPolicyExecutor retryPolicyExecutor,
         CancellationToken cancellationToken = default

src/Ydb.Sdk/src/Ado/YdbDataSource.cs

@@ -88,7 +88,7 @@ async ValueTask<YdbConnection> OpenConnectionAsync(CancellationToken cancellatio
 
         try
         {
-            await ydbConnection.OpenAsync(_retryPolicyExecutor, cancellationToken);
+            await ydbConnection.OpenAsync(cancellationToken);
             return ydbConnection;
         }
         catch

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

@@ -535,18 +535,17 @@ public async Task EnableImplicitSession_TwoSequentialCommands_ReusesSameSession(
 
         var cmd1 = conn.CreateCommand();
         cmd1.CommandText = "SELECT 1;";
-        var result1 = await cmd1.ExecuteScalarAsync();
+        await cmd1.ExecuteScalarAsync();
 
         var s1 = conn.Session;
 
         var cmd2 = conn.CreateCommand();
         cmd2.CommandText = "SELECT 2;";
-        var result2 = await cmd2.ExecuteScalarAsync();
+        await cmd2.ExecuteScalarAsync();
 
         var s2 = conn.Session;
 
         Assert.Equal(s1, s2);
-        
     }
 
     [Fact]
@@ -579,11 +578,12 @@ public async Task ClearPool_FireAndForget_DoesNotBlock_And_PoolsRecreate()
             Assert.Equal(1L, Convert.ToInt64(await cmd.ExecuteScalarAsync()));
         }
 
-        var clearPooledTask   = YdbConnection.ClearPool(new YdbConnection(csPooled));
+        var clearPooledTask = YdbConnection.ClearPool(new YdbConnection(csPooled));
         var clearImplicitTask = YdbConnection.ClearPool(new YdbConnection(csImplicit));
 
-        var done = await Task.WhenAny(Task.WhenAll(clearPooledTask, clearImplicitTask), Task.Delay(TimeSpan.FromSeconds(2)));
-        Assert.True(done is not null && done != Task.Delay(TimeSpan.FromSeconds(2)), "ClearPool() must not block.");
+        var done = await Task.WhenAny(Task.WhenAll(clearPooledTask, clearImplicitTask),
+            Task.Delay(TimeSpan.FromSeconds(2)));
+        Assert.True(done != Task.Delay(TimeSpan.FromSeconds(2)), "ClearPool() must not block.");
 
         await using (var checkPooled = new YdbConnection(csPooled))
         {

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

@@ -1,6 +1,6 @@
 using Xunit;
 
-namespace Ydb.Sdk.Ado.Tests.Session;
+namespace Ydb.Sdk.Ado.Tests;
 
 public class YdbImplictConnectionTests : TestBase
 {