diff options
| author | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-13 15:22:36 +0300 |
|---|---|---|
| committer | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-13 17:04:18 +0300 |
| commit | 09c88b035d29fac5fd49de2fbc3c71e2d2a80754 (patch) | |
| tree | a84b5b2de4dcdf85c3b22b9cac7e984aebb8b68d /yt/cpp/mapreduce/client/retry_heavy_write_request.cpp | |
| parent | 615edba542d9394b0eae47ef957ec2257549cfdd (diff) | |
| download | ydb-09c88b035d29fac5fd49de2fbc3c71e2d2a80754.tar.gz | |
yt/cpp/mapreduce: move Get, TryGet, Exists, MultisetAttributes to THttpRawClient
commit_hash:bd2228f98fa92de408ca850f9bc1608fdf99e7f5
Diffstat (limited to 'yt/cpp/mapreduce/client/retry_heavy_write_request.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/retry_heavy_write_request.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp index 253d7c0d44..44c7db3a97 100644 --- a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp +++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp @@ -25,6 +25,7 @@ using ::ToString; //////////////////////////////////////////////////////////////////////////////// void RetryHeavyWriteRequest( + const IRawClientPtr& rawClient, const IClientRetryPolicyPtr& clientRetryPolicy, const ITransactionPingerPtr& transactionPinger, const TClientContext& context, @@ -44,7 +45,7 @@ void RetryHeavyWriteRequest( } for (int attempt = 0; attempt < retryCount; ++attempt) { - TPingableTransaction attemptTx(clientRetryPolicy, context, parentId, transactionPinger->GetChildTxPinger(), TStartTransactionOptions()); + TPingableTransaction attemptTx(rawClient, clientRetryPolicy, context, parentId, transactionPinger->GetChildTxPinger(), TStartTransactionOptions()); auto input = streamMaker(); TString requestId; @@ -167,6 +168,7 @@ void THeavyRequestRetrier::TryStartAttempt() { Attempt_ = std::make_unique<TAttempt>(); Attempt_->Transaction = std::make_unique<TPingableTransaction>( + Parameters_.RawClientPtr, Parameters_.ClientRetryPolicy, Parameters_.Context, Parameters_.TransactionId, Parameters_.TransactionPinger->GetChildTxPinger(), |