diff --git a/src/frontend/src/instance/grpc.rs b/src/frontend/src/instance/grpc.rs index 49c3e4c6e0..efc5350b2c 100644 --- a/src/frontend/src/instance/grpc.rs +++ b/src/frontend/src/instance/grpc.rs @@ -217,13 +217,8 @@ impl Instance { }; if let Some(flow_proxy) = &self.flow { - flow_proxy - .flow_client - .lock() - .await - .handle(full_req) - .await - .unwrap(); + let mut client = flow_proxy.flow_client.lock().await.clone(); + client.handle(full_req).await.unwrap(); } else { info!("flow proxy is not initialized"); }