making sure that we don't try to reassign dormant node 0. 1.8.2

JasperFx · Oct 10, 2023 · c533aab · c533aab
1 parent 2b18777
commit c533aab
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Directory.Build.props b/Directory.Build.props
@@ -11,7 +11,7 @@
         <TargetFrameworks>net6.0;net7.0</TargetFrameworks>
         <NoWarn>1570;1571;1572;1573;1574;1587;1591;1701;1702;1711;1735;0618</NoWarn>
         <ImplicitUsings>true</ImplicitUsings>
-        <Version>1.8.1</Version>
+        <Version>1.8.2</Version>
         <RepositoryUrl>$(PackageProjectUrl)</RepositoryUrl>
         <PublishRepositoryUrl>true</PublishRepositoryUrl>
         <EmbedUntrackedSources>true</EmbedUntrackedSources>

diff --git a/src/Persistence/Wolverine.RDBMS/Durability/ReassignDormantNodes.cs b/src/Persistence/Wolverine.RDBMS/Durability/ReassignDormantNodes.cs
@@ -21,7 +21,7 @@ public ReassignDormantNodes(INodeAgentPersistence nodes, IMessageDatabase databa
     public async IAsyncEnumerable<object> ExecuteAsync(IWolverineRuntime runtime, [EnumeratorCancellation] CancellationToken cancellationToken)
     {
         var sql =
-            $"select distinct owner_id from {_database.SchemaName}.{DatabaseConstants.IncomingTable} union select distinct owner_id from {_database.SchemaName}.{DatabaseConstants.OutgoingTable};";
+            $"select distinct owner_id from {_database.SchemaName}.{DatabaseConstants.IncomingTable} where owner_id > 0 union select distinct owner_id from {_database.SchemaName}.{DatabaseConstants.OutgoingTable} where owner_id > 0;";
 
         await using var conn = _database.CreateConnection();
         await conn.OpenAsync(cancellationToken);