Merge pull request #672 from huanghaoyuanhhy/fix-flush-ctx

yelusion2 · web-flow · commit 19452bc7cc5c · 2025-05-29T15:08:52.000+08:00
client: use outside ctx
diff --git a/core/client/grpc.go b/core/client/grpc.go
@@ -498,8 +498,6 @@ func (g *GrpcClient) Flush(ctx context.Context, db, collName string) (*milvuspb.
 }
 
 func (g *GrpcClient) checkFlush(ctx context.Context, segIDs []int64, flushTS uint64, ns namespace.NS) error {
-	ctx = g.newCtxWithDB(ctx, ns.DBName())
-
 	start := time.Now()
 	ticker := time.NewTicker(time.Second)
 	defer ticker.Stop()

Original file line number	Diff line number	Diff line change
`@@ -498,8 +498,6 @@ func (g GrpcClient) Flush(ctx context.Context, db, collName string) (milvuspb.`
`498`	`498`	`}`
`499`	`499`
`500`	`500`	`func (g *GrpcClient) checkFlush(ctx context.Context, segIDs []int64, flushTS uint64, ns namespace.NS) error {`
`501`		`- ctx = g.newCtxWithDB(ctx, ns.DBName())`
`502`		`-`
`503`	`501`	`start := time.Now()`
`504`	`502`	`ticker := time.NewTicker(time.Second)`
`505`	`503`	`defer ticker.Stop()`