ignore unreachable version

skbkontur · Jul 1, 2024 · bb46b42 · bb46b42
1 parent 9014083
commit bb46b42
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Cassandra.ThriftClient/Connections/ClusterConnection.cs b/Cassandra.ThriftClient/Connections/ClusterConnection.cs
@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
+using System.Linq;
 using System.Text;
 
 using SkbKontur.Cassandra.ThriftClient.Abstractions;
@@ -60,7 +61,7 @@ public void WaitUntilSchemaAgreementIsReached(TimeSpan timeout)
             {
                 var schemaAgreementCommand = new SchemaAgreementCommand();
                 commandExecutor.Execute(schemaAgreementCommand);
-                if (schemaAgreementCommand.Output.Count == 1)
+                if (schemaAgreementCommand.Output.Keys.Count(x => x != "UNREACHABLE") == 1)
                     return;
                 LogVersions(schemaAgreementCommand.Output);
             } while (sw.Elapsed < timeout);