Intermediate changes

commit_hash:d8d82bf12a346219a4f7637796a6d71aab5fda3c

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