File tree Expand file tree Collapse file tree 1 file changed +2
-14
lines changed Expand file tree Collapse file tree 1 file changed +2
-14
lines changed Original file line number Diff line number Diff line change @@ -682,21 +682,9 @@ impl Proxy for ProxyService {
682
682
683
683
// FIXME: copypasta from execute(), creatively extract to a helper function
684
684
let lock = self . clients . upgradable_read ( ) . await ;
685
- let ( connection_maker, _new_frame_notifier ) = self
685
+ let connection_maker = self
686
686
. namespaces
687
- . with ( ctx. namespace ( ) . clone ( ) , |ns| {
688
- let connection_maker = ns. db . connection_maker ( ) ;
689
- let notifier = ns
690
- . db
691
- . as_primary ( )
692
- . unwrap ( )
693
- . wal_wrapper
694
- . wrapper ( )
695
- . logger ( )
696
- . new_frame_notifier
697
- . subscribe ( ) ;
698
- ( connection_maker, notifier)
699
- } )
687
+ . with ( ctx. namespace ( ) . clone ( ) , |ns| ns. db . connection_maker ( ) )
700
688
. await
701
689
. map_err ( |e| {
702
690
if let crate :: error:: Error :: NamespaceDoesntExist ( _) = e {
You can’t perform that action at this time.
0 commit comments