Set empty revision for tests

2 files changed, 5 insertions, 2 deletions

diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
index bc53442f986..bfd7a4f4673 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp
@@ -1753,7 +1753,9 @@ public:
         , FileCache(options.FileCache)
         , Args {"yql@child", "tasks_runner_proxy"}
         , Env(options.Env)
-        , Revision(GetProgramCommitId())
+        , Revision(options.Revision
+            ? *options.Revision
+            : GetProgramCommitId())
         , TaskScheduler(1)
         , MaxProcesses(options.MaxProcesses)
         , PortoCtlPath(options.PortoCtlPath)
@@ -1895,7 +1897,7 @@ private:
         }
 
         TString exePath;
-        if (executorId.empty() || executorId == Revision) {
+        if (executorId.empty() || Revision.empty() || executorId == Revision) {
             exePath = ExePath;
         } else {
             auto maybeExeFile = FileCache->FindFile(executorId);
diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.h b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.h
index 137a0e8c0c5..6508e82010b 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.h
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.h
@@ -17,6 +17,7 @@ struct TPipeFactoryOptions {
     int MaxProcesses = 1;
     TString ContainerName;
     TString PortoCtlPath = "/usr/bin/porto";
+    TMaybe<TString> Revision; // revision override for tests
 };
 
 IProxyFactory::TPtr CreatePipeFactory(const TPipeFactoryOptions& options);