diff options
| author | hiddenpath <[email protected]> | 2025-04-08 15:34:49 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2025-04-08 15:51:29 +0300 |
| commit | 75d743d97bd309e976e013b80fbeda5d99696bd3 (patch) | |
| tree | adcca76d5321c0a1cb74daf4f5280746634d09d9 /yt/cpp | |
| parent | b005f513a413516a4af89f4c341d92d3ee0ca1bd (diff) | |
Add EnableRpcProxyInJobProxy option to TUserJobSpec
commit_hash:066f704ba92da58c63ac8af6f9032f6c2672a9be
Diffstat (limited to 'yt/cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/operation.cpp | 1 | ||||
| -rw-r--r-- | yt/cpp/mapreduce/interface/operation.h | 9 |
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_; |
