diff --git a/src/Persistence/Wolverine.Postgresql/PostgresqlNodePersistence.cs b/src/Persistence/Wolverine.Postgresql/PostgresqlNodePersistence.cs
index 06eb6db61..e749717ad 100644
--- a/src/Persistence/Wolverine.Postgresql/PostgresqlNodePersistence.cs
+++ b/src/Persistence/Wolverine.Postgresql/PostgresqlNodePersistence.cs
@@ -362,113 +362,3 @@ private async Task<WolverineNode> readNodeAsync(DbDataReader reader)
         return null;
     }
 }
-
-internal class AdvisoryLock : IAdvisoryLock
-{
-    private readonly string _databaseName;
-    private readonly List<int> _locks = new();
-    private readonly ILogger _logger;
-    private readonly NpgsqlDataSource _source;
-    private NpgsqlConnection _conn;
-
-    public AdvisoryLock(NpgsqlDataSource source, ILogger logger, string databaseName)
-    {
-        _source = source;
-        _logger = logger;
-        _databaseName = databaseName;
-    }
-
-    public bool HasLock(int lockId)
-    {
-        return _conn is not { State: ConnectionState.Closed } && _locks.Contains(lockId);
-    }
-
-    public async Task<bool> TryAttainLockAsync(int lockId, CancellationToken token)
-    {
-        if (_conn == null)
-        {
-            _conn = _source.CreateConnection();
-            await _conn.OpenAsync(token).ConfigureAwait(false);
-        }
-
-        if (_conn.State == ConnectionState.Closed)
-        {
-            try
-            {
-                await _conn.DisposeAsync().ConfigureAwait(false);
-            }
-            catch (Exception e)
-            {
-                _logger.LogError(e, "Error trying to clean up and restart an advisory lock connection");
-            }
-            finally
-            {
-                _conn = null;
-            }
-
-            return false;
-        }
-
-
-        var attained = await _conn.TryGetGlobalLock(lockId, token).ConfigureAwait(false);
-        if (attained == AttainLockResult.Success)
-        {
-            _locks.Add(lockId);
-            return true;
-        }
-
-        return false;
-    }
-
-    public async Task ReleaseLockAsync(int lockId)
-    {
-        if (!_locks.Contains(lockId))
-        {
-            return;
-        }
-
-        if (_conn == null || _conn.State == ConnectionState.Closed)
-        {
-            _locks.Remove(lockId);
-            return;
-        }
-
-        var cancellation = new CancellationTokenSource();
-        cancellation.CancelAfter(1.Seconds());
-
-        await _conn.ReleaseGlobalLock(lockId, cancellation.Token).ConfigureAwait(false);
-        _locks.Remove(lockId);
-
-        if (!_locks.Any())
-        {
-            await _conn.CloseAsync().ConfigureAwait(false);
-            await _conn.DisposeAsync().ConfigureAwait(false);
-            _conn = null;
-        }
-    }
-
-    public async ValueTask DisposeAsync()
-    {
-        if (_conn == null)
-        {
-            return;
-        }
-
-        try
-        {
-            foreach (var i in _locks) await _conn.ReleaseGlobalLock(i, CancellationToken.None).ConfigureAwait(false);
-
-            await _conn.CloseAsync().ConfigureAwait(false);
-            await _conn.DisposeAsync().ConfigureAwait(false);
-        }
-        catch (Exception e)
-        {
-            _logger.LogError(e, "Error trying to dispose of advisory locks for database {Identifier}",
-                _databaseName);
-        }
-        finally
-        {
-            await _conn.DisposeAsync().ConfigureAwait(false);
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/Persistence/Wolverine.Postgresql/Wolverine.Postgresql.csproj b/src/Persistence/Wolverine.Postgresql/Wolverine.Postgresql.csproj
index c2f9ccaa7..a44d0deb0 100644
--- a/src/Persistence/Wolverine.Postgresql/Wolverine.Postgresql.csproj
+++ b/src/Persistence/Wolverine.Postgresql/Wolverine.Postgresql.csproj
@@ -15,7 +15,7 @@
     </ItemGroup>
 
     <ItemGroup>
-      <PackageReference Include="Weasel.Postgresql" Version="8.3.1" />
+      <PackageReference Include="Weasel.Postgresql" Version="8.4.1" />
     </ItemGroup>
 
     <Import Project="../../../Analysis.Build.props" />
diff --git a/src/Persistence/Wolverine.RDBMS/Wolverine.RDBMS.csproj b/src/Persistence/Wolverine.RDBMS/Wolverine.RDBMS.csproj
index 57a3949d7..f1739c816 100644
--- a/src/Persistence/Wolverine.RDBMS/Wolverine.RDBMS.csproj
+++ b/src/Persistence/Wolverine.RDBMS/Wolverine.RDBMS.csproj
@@ -14,7 +14,7 @@
     </ItemGroup>
 
     <ItemGroup>
-      <PackageReference Include="Weasel.Core" Version="8.3.1" />
+      <PackageReference Include="Weasel.Core" Version="8.4.1" />
     </ItemGroup>
 
     <Import Project="../../../Analysis.Build.props" />
diff --git a/src/Persistence/Wolverine.SqlServer/Wolverine.SqlServer.csproj b/src/Persistence/Wolverine.SqlServer/Wolverine.SqlServer.csproj
index b40d46eac..dce2aaaeb 100644
--- a/src/Persistence/Wolverine.SqlServer/Wolverine.SqlServer.csproj
+++ b/src/Persistence/Wolverine.SqlServer/Wolverine.SqlServer.csproj
@@ -13,7 +13,7 @@
         <EmbeddedResource Include="Schema/*.sql" />
     </ItemGroup>
     <ItemGroup>
-      <PackageReference Include="Weasel.SqlServer" Version="8.3.1" />
+      <PackageReference Include="Weasel.SqlServer" Version="8.4.1" />
     </ItemGroup>
 
     <Import Project="../../../Analysis.Build.props" />