From c533aab2a056291f13913e1656a873caddd5e4e4 Mon Sep 17 00:00:00 2001 From: "Jeremy D. Miller" Date: Tue, 10 Oct 2023 08:05:51 -0500 Subject: [PATCH] making sure that we don't try to reassign dormant node 0. 1.8.2 --- Directory.Build.props | 2 +- .../Wolverine.RDBMS/Durability/ReassignDormantNodes.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Directory.Build.props b/Directory.Build.props index 74a31832c..c6b50a5a3 100644 --- a/Directory.Build.props +++ b/Directory.Build.props @@ -11,7 +11,7 @@ net6.0;net7.0 1570;1571;1572;1573;1574;1587;1591;1701;1702;1711;1735;0618 true - 1.8.1 + 1.8.2 $(PackageProjectUrl) true true diff --git a/src/Persistence/Wolverine.RDBMS/Durability/ReassignDormantNodes.cs b/src/Persistence/Wolverine.RDBMS/Durability/ReassignDormantNodes.cs index 66e296061..6bde51e41 100644 --- 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 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);