From 6d3dd6fee98625ae87b2b579b1eaf8f51a1355eb Mon Sep 17 00:00:00 2001 From: ad hoc Date: Wed, 24 Jul 2024 14:38:20 +0200 Subject: [PATCH] fix describe proxy impl --- libsql-server/src/rpc/proxy.rs | 16 ++-------------- 1 file changed, 2 insertions(+), 14 deletions(-) diff --git a/libsql-server/src/rpc/proxy.rs b/libsql-server/src/rpc/proxy.rs index 3164ee88bb..2899ab435c 100644 --- a/libsql-server/src/rpc/proxy.rs +++ b/libsql-server/src/rpc/proxy.rs @@ -682,21 +682,9 @@ impl Proxy for ProxyService { // FIXME: copypasta from execute(), creatively extract to a helper function let lock = self.clients.upgradable_read().await; - let (connection_maker, _new_frame_notifier) = self + let connection_maker = self .namespaces - .with(ctx.namespace().clone(), |ns| { - let connection_maker = ns.db.connection_maker(); - let notifier = ns - .db - .as_primary() - .unwrap() - .wal_wrapper - .wrapper() - .logger() - .new_frame_notifier - .subscribe(); - (connection_maker, notifier) - }) + .with(ctx.namespace().clone(), |ns| ns.db.connection_maker()) .await .map_err(|e| { if let crate::error::Error::NamespaceDoesntExist(_) = e {