diff options
| author | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-15 20:17:09 +0300 |
|---|---|---|
| committer | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-15 21:21:14 +0300 |
| commit | bb37d56338bace93813adc51a61936a19acc8edc (patch) | |
| tree | 3d771660421001c994e2baf9a40b409d06c7a24b /yt/cpp/mapreduce/client/batch_request_impl.cpp | |
| parent | 9a04c0af35c6a47061b3699089da07acfcf14587 (diff) | |
| download | ydb-bb37d56338bace93813adc51a61936a19acc8edc.tar.gz | |
YT-23616: Make THttpRawBatchRequest as an implementation of IRawBatchRequest interface
commit_hash:9e6c556686dda1562697762d38da532dc5c87b80
Diffstat (limited to 'yt/cpp/mapreduce/client/batch_request_impl.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/batch_request_impl.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp index f45eee319b..e7456b9187 100644 --- a/yt/cpp/mapreduce/client/batch_request_impl.cpp +++ b/yt/cpp/mapreduce/client/batch_request_impl.cpp @@ -36,11 +36,11 @@ using ::NThreading::NewPromise; TBatchRequest::TBatchRequest(const TTransactionId& defaultTransaction, ::TIntrusivePtr<TClient> client) : DefaultTransaction_(defaultTransaction) - , Impl_(MakeIntrusive<THttpRawBatchRequest>(client->GetContext().Config)) + , Impl_(client->GetRawClient()->CreateRawBatchRequest()) , Client_(client) { } -TBatchRequest::TBatchRequest(THttpRawBatchRequest* impl, ::TIntrusivePtr<TClient> client) +TBatchRequest::TBatchRequest(IRawBatchRequest* impl, ::TIntrusivePtr<TClient> client) : Impl_(impl) , Client_(std::move(client)) { } @@ -189,7 +189,7 @@ TFuture<TCheckPermissionResponse> TBatchRequest::CheckPermission( void TBatchRequest::ExecuteBatch(const TExecuteBatchOptions& options) { - Impl_->ExecuteBatch(Client_->GetRetryPolicy()->CreatePolicyForGenericRequest(), Client_->GetContext(), options); + Impl_->ExecuteBatch(options); } //////////////////////////////////////////////////////////////////////////////// |