aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2024-12-24 22:18:54 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2024-12-24 22:37:56 +0300
commit8fa83915202633143936bfce16cf1c06653e2dce (patch)
tree49c891bc3ea761cfbec7479a2e169a1bde8231a0 /yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.cpp
parent845baeff50212ec002c6a67e16bdf7c03c997fbf (diff)
downloadydb-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.cpp16
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;