Skip to content

Commit

Permalink
move incrBackupImplTable one level above
Browse files Browse the repository at this point in the history
  • Loading branch information
Enjection committed May 29, 2024
1 parent a904692 commit 1bbeeb7
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ TVector<ISubOperation::TPtr> CreateAlterContinuousBackup(TOperationId opId, cons
const auto topicPath = streamPath.Child("streamImpl");
TTopicInfo::TPtr topic = context.SS->Topics.at(topicPath.Base()->PathId);

const auto backupTablePath = streamPath.Child("incBackupImpl");
const auto backupTablePath = tablePath.Child("incBackupImpl");

const NScheme::TTypeRegistry* typeRegistry = AppData(context.Ctx)->TypeRegistry;

Expand Down
5 changes: 5 additions & 0 deletions ydb/core/tx/schemeshard/schemeshard_impl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -6693,6 +6693,11 @@ void TSchemeShard::FillTableDescriptionForShardIdx(
break;
}

case NKikimrSchemeOp::EPathTypeTable: {
// TODO: move BackupImplTable under special scheme element
break;
}

default:
Y_FAIL_S("Unexpected table's child"
<< ": tableId# " << tableId
Expand Down
3 changes: 3 additions & 0 deletions ydb/core/tx/schemeshard/schemeshard_path_describer.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -372,6 +372,9 @@ void TPathDescriber::DescribeTable(const TActorContext& ctx, TPathId pathId, TPa
case NKikimrSchemeOp::EPathTypeSequence:
Self->DescribeSequence(childPathId, childName, *entry->AddSequences(), returnSetVal);
break;
case NKikimrSchemeOp::EPathTypeTable:
// TODO: move BackupImplTable under special scheme element
break;
default:
Y_FAIL_S("Unexpected table's child"
<< ": tableId# " << pathId
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ Y_UNIT_TEST_SUITE(TContinuousBackupTests) {
NLs::HasOffloadConfig,
});

TestDescribeResult(DescribePrivatePath(runtime, "/MyRoot/Table/continuousBackupImpl/incBackupImpl"), {
TestDescribeResult(DescribePrivatePath(runtime, "/MyRoot/Table/incBackupImpl"), {
NLs::PathExist,
NLs::IsTable,
NLs::CheckColumns("incBackupImpl", {"key", "value", "__incrBackupImpl_deleted"}, {}, {"key"}),
Expand Down

0 comments on commit 1bbeeb7

Please sign in to comment.