From 83666f1bffa48324f459b85ae37e6057201aed67 Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Tue, 21 Jan 2025 10:29:04 +0800 Subject: [PATCH] enhance: [2.5] Enable hook for importv2 (#39430) /kind improvement pr: https://github.com/milvus-io/milvus/pull/39429 Signed-off-by: bigsheeper --- internal/distributed/proxy/httpserver/handler_v2.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/distributed/proxy/httpserver/handler_v2.go b/internal/distributed/proxy/httpserver/handler_v2.go index c9f8c0f44c..94c64d8750 100644 --- a/internal/distributed/proxy/httpserver/handler_v2.go +++ b/internal/distributed/proxy/httpserver/handler_v2.go @@ -2525,7 +2525,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 {