YT-26906: start session from tx

* Changelog entry
  Type: feature
  Component: cpp-sdk

Start distributed session methods (file/table) now support attaching to transaction.
commit_hash:0a40dfd6d556f9890fa5abccf29c0baf33df4e7d

1 files changed, 4 insertions, 2 deletions

diff --git a/yt/cpp/mapreduce/rpc_client/raw_client.cpp b/yt/cpp/mapreduce/rpc_client/raw_client.cpp
index 86ee9a477ed..73f185ba0c5 100644
--- a/yt/cpp/mapreduce/rpc_client/raw_client.cpp
+++ b/yt/cpp/mapreduce/rpc_client/raw_client.cpp
@@ -1434,13 +1434,14 @@ TCheckPermissionResponse ParseCheckPermissionResponse(const NApi::TCheckPermissi
 
 TDistributedWriteTableSessionWithCookies TRpcRawClient::StartDistributedWriteTableSession(
     TMutationId& mutationId,
+    const TTransactionId& transactionId,
     const TRichYPath& richPath,
     i64 cookieCount,
     const TStartDistributedWriteTableOptions& options)
 {
     auto future = Client_->StartDistributedWriteSession(
         ToApiRichPath(richPath),
-        SerializeOptionsForStartDistributedTableSession(mutationId, cookieCount, options));
+        SerializeOptionsForStartDistributedTableSession(mutationId, transactionId, cookieCount, options));
 
     auto apiSession = WaitAndProcess(future);
 
@@ -1588,13 +1589,14 @@ std::unique_ptr<IOutputStreamWithResponse> TRpcRawClient::WriteTableFragment(
 
 TDistributedWriteFileSessionWithCookies TRpcRawClient::StartDistributedWriteFileSession(
     TMutationId& mutationId,
+    const TTransactionId& transactionId,
     const TRichYPath& richPath,
     i64 cookieCount,
     const TStartDistributedWriteFileOptions& options)
 {
     auto future = Client_->StartDistributedWriteFileSession(
         ToApiRichPath(richPath),
-        SerializeOptionsForStartDistributedFileSession(mutationId, cookieCount, options));
+        SerializeOptionsForStartDistributedFileSession(mutationId, transactionId, cookieCount, options));
 
     auto apiSession = WaitAndProcess(future);