repair delete case (#400)

Signed-off-by: wayblink <[email protected]>
zilliztech · Aug 19, 2024 · 7250521 · 7250521
1 parent 8672ef8
commit 7250521
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/core/backup_impl_restore_backup.go b/core/backup_impl_restore_backup.go
@@ -752,9 +752,17 @@ func (b *BackupContext) executeBulkInsert(ctx context.Context, db, coll string,
 	var taskId int64
 	var err error
 	if endTime == 0 {
-		taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsBackup(), gomilvus.IsL0(isL0), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck))
+		if isL0 {
+			taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsL0(isL0), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck))
+		} else {
+			taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsBackup(), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck))
+		}
 	} else {
-		taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsBackup(), gomilvus.IsL0(isL0), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck), gomilvus.WithEndTs(endTime))
+		if isL0 {
+			taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsL0(isL0), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck), gomilvus.WithEndTs(endTime))
+		} else {
+			taskId, err = b.getMilvusClient().BulkInsert(ctx, db, coll, partition, files, gomilvus.IsBackup(), gomilvus.SkipDiskQuotaCheck(skipDiskQuotaCheck), gomilvus.WithEndTs(endTime))
+		}
 	}
 	if err != nil {
 		log.Error("fail to bulk insert",