minor fix

alibaba · Nov 21, 2024 · 3d21285 · 3d21285
1 parent 583b58d
commit 3d21285
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...ve_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcInterceptor.java b/...ve_engine/compiler/src/main/java/com/alibaba/graphscope/common/client/RpcInterceptor.java
@@ -42,11 +42,6 @@ public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
             public void start(Listener<RespT> responseListener, Metadata headers) {
                 requestStartTime = Instant.now();
                 QueryLogger queryLogger = callOptions.getOption(QUERY_LOGGER_OPTION);
-                if (queryLogger != null) {
-                    queryLogger.info(
-                            "[query][submitted]: submit the query to the channel {}",
-                            channel.authority());
-                }
                 super.start(
                         new ForwardingClientCallListener.SimpleForwardingClientCallListener<RespT>(
                                 responseListener) {
@@ -86,6 +81,11 @@ public void onClose(Status status, Metadata trailers) {
                             }
                         },
                         headers);
+                if (queryLogger != null) {
+                    queryLogger.info(
+                            "[query][submitted]: submit the query to the task queue of channel {}",
+                            channel.authority());
+                }
             }
         };
     }