diff options
author | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-24 22:18:54 +0300 |
---|---|---|
committer | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-24 22:37:56 +0300 |
commit | 8fa83915202633143936bfce16cf1c06653e2dce (patch) | |
tree | 49c891bc3ea761cfbec7479a2e169a1bde8231a0 /yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp | |
parent | 845baeff50212ec002c6a67e16bdf7c03c997fbf (diff) | |
download | ydb-8fa83915202633143936bfce16cf1c06653e2dce.tar.gz |
YT-23616: Move start_op to THttpRawClient
commit_hash:dea4a6f4cd03d1ce40a117dbe660e14750dc6da5
Diffstat (limited to 'yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp')
-rw-r--r-- | yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp | 16 |
1 files changed, 15 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp index 2869ddcc0f..98ef5ed099 100644 --- a/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp +++ b/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp @@ -393,7 +393,21 @@ TNode SerializeParamsForListOperations( return result; } -TNode SerializeParamsForGetOperation(const std::variant<TString, TOperationId>& aliasOrOperationId, const TGetOperationOptions& options) +TNode SerializeParamsForStartOperation( + const TTransactionId& transactionId, + EOperationType type, + const TNode& spec) +{ + TNode result; + SetTransactionIdParam(&result, transactionId); + result["operation_type"] = ToString(type); + result["spec"] = spec; + return result; +} + +TNode SerializeParamsForGetOperation( + const std::variant<TString, TOperationId>& aliasOrOperationId, + const TGetOperationOptions& options) { auto includeRuntime = options.IncludeRuntime_; TNode result; |