diff options
Diffstat (limited to 'yt/cpp/mapreduce/client/transaction.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/transaction.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/yt/cpp/mapreduce/client/transaction.cpp b/yt/cpp/mapreduce/client/transaction.cpp index 289c89340e6..9790f8c8807 100644 --- a/yt/cpp/mapreduce/client/transaction.cpp +++ b/yt/cpp/mapreduce/client/transaction.cpp @@ -129,9 +129,9 @@ void TPingableTransaction::Ping() const RawClient_->PingTransaction(TransactionId_); } -void TPingableTransaction::Commit() +void TPingableTransaction::Commit(const TCommitTransactionOptions& options) { - Stop(EStopAction::Commit); + Stop(EStopAction::Commit, options); } void TPingableTransaction::Abort() @@ -144,7 +144,7 @@ void TPingableTransaction::Detach() Stop(EStopAction::Detach); } -void TPingableTransaction::Stop(EStopAction action) +void TPingableTransaction::Stop(EStopAction action, const TCommitTransactionOptions& commitOptions) { if (Finalized_) { return; @@ -161,8 +161,8 @@ void TPingableTransaction::Stop(EStopAction action) case EStopAction::Commit: NDetail::RequestWithRetry<void>( ClientRetryPolicy_->CreatePolicyForGenericRequest(), - [this] (TMutationId& mutationId) { - RawClient_->CommitTransaction(mutationId, TransactionId_); + [this, &commitOptions] (TMutationId& mutationId) { + RawClient_->CommitTransaction(mutationId, TransactionId_, commitOptions); }); break; case EStopAction::Abort: |
