diff options
author | robot-piglet <robot-piglet@yandex-team.com> | 2025-02-11 17:46:25 +0300 |
---|---|---|
committer | robot-piglet <robot-piglet@yandex-team.com> | 2025-02-11 18:07:00 +0300 |
commit | 8b363a039a2bc94a03da342d5cffe4b723e63a21 (patch) | |
tree | f6beda764d8c16b1712c9369875b4475ef7cbe3d /yt/yql/tools | |
parent | 749393b0956db42603f026990b66966bf84bffa1 (diff) | |
download | ydb-8b363a039a2bc94a03da342d5cffe4b723e63a21.tar.gz |
Intermediate changes
commit_hash:d8d82bf12a346219a4f7637796a6d71aab5fda3c
Diffstat (limited to 'yt/yql/tools')
-rw-r--r-- | yt/yql/tools/ytrun/lib/ytrun_lib.cpp | 12 | ||||
-rw-r--r-- | yt/yql/tools/ytrun/lib/ytrun_lib.h | 2 |
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 |