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 {