Skip to content

Commit 65d1e86

Browse files
authored
Little cosmetic changes (#14273)
1 parent 44bae67 commit 65d1e86

File tree

2 files changed

+12
-11
lines changed

2 files changed

+12
-11
lines changed

ydb/public/lib/ydb_cli/dump/restore_impl.cpp

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -274,8 +274,8 @@ TRestoreResult TRestoreClient::Restore(const TString& fsPath, const TString& dbP
274274
LOG_D("Resolved db base path: " << dbBasePath.GetPath().Quote());
275275

276276
auto oldDirectoryList = RecursiveList(SchemeClient, dbBasePath);
277-
if (!oldDirectoryList.Status.IsSuccess()) {
278-
LOG_E("Error listing db base path: " << dbBasePath.GetPath().Quote() << ": " << oldDirectoryList.Status.GetIssues().ToOneLineString());
277+
if (const auto& status = oldDirectoryList.Status; !status.IsSuccess()) {
278+
LOG_E("Error listing db base path: " << dbBasePath.GetPath().Quote() << ": " << status.GetIssues().ToOneLineString());
279279
return Result<TRestoreResult>(EStatus::SCHEME_ERROR, "Can not list existing directory");
280280
}
281281

@@ -489,9 +489,8 @@ TRestoreResult TRestoreClient::RestoreView(
489489
TString query = TFileInput(createViewFile).ReadAll();
490490

491491
NYql::TIssues issues;
492-
if (!RewriteCreateViewQuery(query, dbRestoreRoot, IsDatabase(SchemeClient, dbRestoreRoot), dbPath,
493-
createViewFile.GetPath().Quote(), issues
494-
)) {
492+
const bool isDb = IsDatabase(SchemeClient, dbRestoreRoot);
493+
if (!RewriteCreateViewQuery(query, dbRestoreRoot, isDb, dbPath, createViewFile.GetPath().Quote(), issues)) {
495494
return Result<TRestoreResult>(dbPath, EStatus::BAD_REQUEST, issues.ToString());
496495
}
497496

@@ -565,7 +564,7 @@ TRestoreResult TRestoreClient::RestoreCoordinationNode(
565564
LOG_I("Restore coordination node " << fsPath.GetPath().Quote() << " to " << dbPath.Quote());
566565

567566
if (settings.DryRun_) {
568-
return CheckExistenceAndType(SchemeClient, dbPath, NScheme::ESchemeEntryType::CoordinationNode);
567+
return CheckExistenceAndType(SchemeClient, dbPath, ESchemeEntryType::CoordinationNode);
569568
}
570569

571570
const auto creationRequest = ReadCoordinationNodeCreationRequest(fsPath, Log.get());
@@ -727,7 +726,7 @@ TRestoreResult TRestoreClient::CreateDataAccumulators(
727726
TVector<THolder<NPrivate::IDataAccumulator>>& outAccumulators,
728727
const TString& dbPath,
729728
const TRestoreSettings& settings,
730-
const NTable::TTableDescription& desc,
729+
const TTableDescription& desc,
731730
ui32 dataFilesCount)
732731
{
733732
const ui32 accumulatorsCount = std::min(settings.InFly_, dataFilesCount);

ydb/public/lib/ydb_cli/dump/restore_import_data.cpp

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -955,10 +955,11 @@ class TDataWriter: public NPrivate::IDataWriter {
955955
} // anonymous
956956

957957
NPrivate::IDataAccumulator* CreateImportDataAccumulator(
958-
const NTable::TTableDescription& dumpedDesc,
959-
const NTable::TTableDescription& actualDesc,
958+
const TTableDescription& dumpedDesc,
959+
const TTableDescription& actualDesc,
960960
const TRestoreSettings& settings,
961-
const std::shared_ptr<TLog>& log) {
961+
const std::shared_ptr<TLog>& log)
962+
{
962963
return new TDataAccumulator(dumpedDesc, actualDesc, settings, log);
963964
}
964965

@@ -969,7 +970,8 @@ NPrivate::IDataWriter* CreateImportDataWriter(
969970
TTableClient& tableClient,
970971
const TVector<THolder<NPrivate::IDataAccumulator>>& accumulators,
971972
const TRestoreSettings& settings,
972-
const std::shared_ptr<TLog>& log) {
973+
const std::shared_ptr<TLog>& log)
974+
{
973975
return new TDataWriter(path, desc, settings, importClient, tableClient, accumulators, log);
974976
}
975977

0 commit comments

Comments
 (0)