aboutsummaryrefslogtreecommitdiffstats
path: root/yt/yql/tools
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2025-02-11 17:46:25 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2025-02-11 18:07:00 +0300
commit8b363a039a2bc94a03da342d5cffe4b723e63a21 (patch)
treef6beda764d8c16b1712c9369875b4475ef7cbe3d /yt/yql/tools
parent749393b0956db42603f026990b66966bf84bffa1 (diff)
downloadydb-8b363a039a2bc94a03da342d5cffe4b723e63a21.tar.gz
Intermediate changes
commit_hash:d8d82bf12a346219a4f7637796a6d71aab5fda3c
Diffstat (limited to 'yt/yql/tools')
-rw-r--r--yt/yql/tools/ytrun/lib/ytrun_lib.cpp12
-rw-r--r--yt/yql/tools/ytrun/lib/ytrun_lib.h2
2 files changed, 7 insertions, 7 deletions
diff --git a/yt/yql/tools/ytrun/lib/ytrun_lib.cpp b/yt/yql/tools/ytrun/lib/ytrun_lib.cpp
index c2064ebd85..ed5a86fc0b 100644
--- a/yt/yql/tools/ytrun/lib/ytrun_lib.cpp
+++ b/yt/yql/tools/ytrun/lib/ytrun_lib.cpp
@@ -176,18 +176,18 @@ IYtGateway::TPtr TYtRunTool::CreateYtGateway() {
return ytGateway;
}
- auto coordinator = MakeFmrCoordinator();
- auto func = [&] (TTask::TPtr /*task*/, std::shared_ptr<std::atomic<bool>> cancelFlag) {
+ auto coordinator = NFmr::MakeFmrCoordinator();
+ auto func = [&] (NFmr::TTask::TPtr /*task*/, std::shared_ptr<std::atomic<bool>> cancelFlag) {
while (!cancelFlag->load()) {
Sleep(TDuration::Seconds(3));
- return ETaskStatus::Completed;
+ return NFmr::ETaskStatus::Completed;
}
- return ETaskStatus::Aborted;
+ return NFmr::ETaskStatus::Aborted;
}; // TODO - use function which actually calls Downloader/Uploader based on task params
- TFmrJobFactorySettings settings{.Function=func};
+ NFmr::TFmrJobFactorySettings settings{.Function=func};
auto jobFactory = MakeFmrJobFactory(settings);
- TFmrWorkerSettings workerSettings{.WorkerId = 1, .RandomProvider = CreateDefaultRandomProvider(),
+ NFmr::TFmrWorkerSettings workerSettings{.WorkerId = 1, .RandomProvider = CreateDefaultRandomProvider(),
.TimeToSleepBetweenRequests=TDuration::Seconds(1)};
FmrWorker_ = MakeFmrWorker(coordinator, jobFactory, workerSettings);
FmrWorker_->Start();
diff --git a/yt/yql/tools/ytrun/lib/ytrun_lib.h b/yt/yql/tools/ytrun/lib/ytrun_lib.h
index e724ce2ac6..96c62a2c33 100644
--- a/yt/yql/tools/ytrun/lib/ytrun_lib.h
+++ b/yt/yql/tools/ytrun/lib/ytrun_lib.h
@@ -33,7 +33,7 @@ protected:
size_t NumThreads_ = 1;
bool KeepTemp_ = false;
TString DefYtServer_;
- IFmrWorker::TPtr FmrWorker_;
+ NFmr::IFmrWorker::TPtr FmrWorker_;
};
} // NYql