fix: update rg failed when alter database (#39355)

issue: #36933

Signed-off-by: chyezh <chyezh@outlook.com>
pull/39479/head
Zhen Ye 2025-01-17 14:27:03 +08:00 committed by GitHub
parent 92bde5b4f6
commit 3ca6c0127d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions

View File

@ -34,6 +34,7 @@ import (
"github.com/milvus-io/milvus/pkg/proto/querypb"
"github.com/milvus-io/milvus/pkg/proto/rootcoordpb"
"github.com/milvus-io/milvus/pkg/util/merr"
"github.com/milvus-io/milvus/pkg/util/typeutil"
)
type alterDatabaseTask struct {
@ -177,7 +178,7 @@ func executeAlterDatabaseTaskSteps(ctx context.Context,
zap.Strings("newResourceGroups", newResourceGroups),
)
redoTask.AddAsyncStep(NewSimpleStep("", func(ctx context.Context) ([]nestedStep, error) {
colls, err := core.meta.ListCollections(ctx, oldDB.Name, ts, true)
colls, err := core.meta.ListCollections(ctx, oldDB.Name, typeutil.MaxTimestamp, true)
if err != nil {
log.Ctx(ctx).Warn("failed to trigger update load config for database", zap.Int64("dbID", oldDB.ID), zap.Error(err))
return nil, err