summaryrefslogtreecommitdiffstats
path: root/yt/cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2025-04-08 15:34:49 +0300
committerhiddenpath <[email protected]>2025-04-08 15:51:29 +0300
commit75d743d97bd309e976e013b80fbeda5d99696bd3 (patch)
treeadcca76d5321c0a1cb74daf4f5280746634d09d9 /yt/cpp
parentb005f513a413516a4af89f4c341d92d3ee0ca1bd (diff)
Add EnableRpcProxyInJobProxy option to TUserJobSpec
commit_hash:066f704ba92da58c63ac8af6f9032f6c2672a9be
Diffstat (limited to 'yt/cpp')
-rw-r--r--yt/cpp/mapreduce/client/operation.cpp1
-rw-r--r--yt/cpp/mapreduce/interface/operation.h9
2 files changed, 10 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp
index 553b1a07776..a885657fb57 100644
--- a/yt/cpp/mapreduce/client/operation.cpp
+++ b/yt/cpp/mapreduce/client/operation.cpp
@@ -782,6 +782,7 @@ void BuildUserJobFluently(
})
.EndList()
.Item("start_queue_consumer_registration_manager").Value(false)
+ .Item("enable_rpc_proxy_in_job_proxy").Value(userJobSpec.EnableRpcProxyInJobProxy_)
.Item("redirect_stdout_to_stderr").Value(preparer.ShouldRedirectStdoutToStderr());
}
diff --git a/yt/cpp/mapreduce/interface/operation.h b/yt/cpp/mapreduce/interface/operation.h
index 50c694b5b06..1f327b4b5d6 100644
--- a/yt/cpp/mapreduce/interface/operation.h
+++ b/yt/cpp/mapreduce/interface/operation.h
@@ -891,6 +891,15 @@ struct TUserJobSpec
/// @see https://ytsaurus.tech/docs/en/user-guide/data-processing/operations/operations-options#disk_request
FLUENT_FIELD_OPTION(TDiskRequest, DiskRequest);
+ ///
+ /// @brief Activates the RPC proxy within the job proxy.
+ ///
+ /// By enabling this option, the environment variable YT_JOB_PROXY_SOCKET_PATH will be set.
+ /// You can use this variable to obtain the unix domain socket path and then construct a client for sending requests.
+ ///
+ /// @note Do not enable this option without prior discussion with the YTsaurus team.
+ FLUENT_FIELD_DEFAULT(bool, EnableRpcProxyInJobProxy, false);
+
private:
TVector<std::tuple<TLocalFilePath, TAddLocalFileOptions>> LocalFiles_;
TJobBinaryConfig JobBinary_;