From 5686a9a024d76a70e9a1303a7cd7da2f7d789ffa Mon Sep 17 00:00:00 2001
From: jaime <yun.zhang@zilliz.com>
Date: Mon, 30 Sep 2024 12:59:16 +0800
Subject: [PATCH] fix: unhandle error in upsert task (#36604)

issue: #36611

Signed-off-by: jaime <yun.zhang@zilliz.com>
---
 internal/proxy/task_upsert.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/proxy/task_upsert.go b/internal/proxy/task_upsert.go
index 825323c1d3..154bbba875 100644
--- a/internal/proxy/task_upsert.go
+++ b/internal/proxy/task_upsert.go
@@ -464,7 +464,7 @@ func (it *upsertTask) deleteExecute(ctx context.Context, msgPack *msgstream.MsgP
 		if !ok {
 			msgid, err := it.idAllocator.AllocOne()
 			if err != nil {
-				errors.Wrap(err, "failed to allocate MsgID for delete of upsert")
+				return errors.Wrap(err, "failed to allocate MsgID for delete of upsert")
 			}
 			sliceRequest := &msgpb.DeleteRequest{
 				Base: commonpbutil.NewMsgBase(