From e09058fe209fd212def0e0dc489d5155f302acab Mon Sep 17 00:00:00 2001 From: dragondriver Date: Wed, 8 Dec 2021 14:47:04 +0800 Subject: [PATCH] Add ut for DropAlias when dd queue is full (#12909) Signed-off-by: dragondriver --- internal/proxy/proxy_test.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/internal/proxy/proxy_test.go b/internal/proxy/proxy_test.go index 3ac16b230c..40e0618207 100644 --- a/internal/proxy/proxy_test.go +++ b/internal/proxy/proxy_test.go @@ -2193,6 +2193,14 @@ func TestProxy(t *testing.T) { assert.NotEqual(t, commonpb.ErrorCode_Success, resp.ErrorCode) }) + wg.Add(1) + t.Run("DropAlias fail, dd queue full", func(t *testing.T) { + defer wg.Done() + resp, err := proxy.DropAlias(ctx, &milvuspb.DropAliasRequest{}) + assert.NoError(t, err) + assert.NotEqual(t, commonpb.ErrorCode_Success, resp.ErrorCode) + }) + proxy.sched.ddQueue.setMaxTaskNum(ddParallel) dmParallelism := proxy.sched.dmQueue.getMaxTaskNum()