enhance: [2.4] Enable hook for importv2 (#39431)

bigsheeper · web-flow · commit d07ae21e8a27 · 2025-01-20T21:13:05.000+08:00
/kind improvement pr: #39429 Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
diff --git a/internal/distributed/proxy/httpserver/handler_v2.go b/internal/distributed/proxy/httpserver/handler_v2.go
@@ -2206,7 +2206,7 @@ func (h *HandlersV2) createImportJob(ctx context.Context, c *gin.Context, anyReq
 			return nil, err
 		}
 	}
-	resp, err := wrapperProxy(ctx, c, req, false, false, "/milvus.proto.milvus.MilvusService/ImportV2", func(reqCtx context.Context, req any) (interface{}, error) {
+	resp, err := wrapperProxy(ctx, c, req, false, false, "/milvus.proto.milvus.MilvusService/Import", func(reqCtx context.Context, req any) (interface{}, error) {
 		return h.proxy.ImportV2(reqCtx, req.(*internalpb.ImportRequest))
 	})
 	if err == nil {

Original file line number	Diff line number	Diff line change
`@@ -2206,7 +2206,7 @@ func (h HandlersV2) createImportJob(ctx context.Context, c gin.Context, anyReq`
`2206`	`2206`	`return nil, err`
`2207`	`2207`	`}`
`2208`	`2208`	`}`
`2209`		`- resp, err := wrapperProxy(ctx, c, req, false, false, "/milvus.proto.milvus.MilvusService/ImportV2", func(reqCtx context.Context, req any) (interface{}, error) {`
	`2209`	`+ resp, err := wrapperProxy(ctx, c, req, false, false, "/milvus.proto.milvus.MilvusService/Import", func(reqCtx context.Context, req any) (interface{}, error) {`
`2210`	`2210`	`return h.proxy.ImportV2(reqCtx, req.(*internalpb.ImportRequest))`
`2211`	`2211`	`})`
`2212`	`2212`	`if err == nil {`