fix: Fix compile error (#35442)

issue: https://github.com/milvus-io/milvus/issues/33285

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
pull/35377/head
yihao.dai 2024-08-13 15:46:19 +08:00 committed by GitHub
parent efadf22802
commit e58d656e65
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions

View File

@ -412,7 +412,7 @@ func (s *broadcastCreatePartitionMsgStep) Execute(ctx context.Context) ([]nested
msgs = append(msgs, msg)
}
resp := streaming.WAL().Append(ctx, msgs...)
if err := resp.IsAnyError(); err != nil {
if err := resp.UnwrapFirstError(); err != nil {
return nil, err
}
return nil, nil