diff --git a/safekeeper/src/handler.rs b/safekeeper/src/handler.rs
index f45bfb95fa..d411aea41d 100644
--- a/safekeeper/src/handler.rs
+++ b/safekeeper/src/handler.rs
@@ -196,6 +196,15 @@ impl<IO: AsyncRead + AsyncWrite + Unpin + Send> postgres_backend::Handler<IO>
         &mut self,
         pgb: &mut PostgresBackend<IO>,
         query_string: &str,
+    ) -> Result<(), QueryError> {
+        self.process_query_(pgb, &query_string).await
+    }
+}
+impl SafekeeperPostgresHandler {
+    async fn process_query_<IO: AsyncRead + AsyncWrite + Send + Unpin>(
+        &mut self,
+        pgb: &mut PostgresBackend<IO>,
+        query_string: &str,
     ) -> Result<(), QueryError> {
         if query_string
             .to_ascii_lowercase()