mt: Fix missing block_in_place

libsqlx-server/src/allocation/primary/mod.rs

@@ -320,7 +320,9 @@ impl ConnectionHandler for PrimaryConnection {
     async fn handle_conn_message(&mut self, msg: ConnectionMessage) {
         match msg {
             ConnectionMessage::Execute { pgm, builder } => {
-                self.conn.execute_program(&pgm, builder).unwrap()
+                block_in_place(|| {
+                    self.conn.execute_program(&pgm, builder).unwrap()
+                })
             }
             ConnectionMessage::Describe => {
                 todo!()

libsqlx-server/src/allocation/replica.rs

@@ -172,6 +172,7 @@ impl Replicator {
     }
 
     async fn query_replicate(&mut self) {
+        tracing::debug!("seinding replication request");
         self.req_id += 1;
         self.next_seq = 0;
         // clear buffered, uncommitted frames