YT-27827: TPingerTransaction use BlockingGet instead of WaitFor in destructor

commit_hash:90bbe36635e0d48c81c153567dcedf28f103efbe

1 files changed, 7 insertions, 5 deletions

diff --git a/yt/cpp/mapreduce/client/transaction.cpp b/yt/cpp/mapreduce/client/transaction.cpp
index 289c89340e6..c54d01f8136 100644
--- a/yt/cpp/mapreduce/client/transaction.cpp
+++ b/yt/cpp/mapreduce/client/transaction.cpp
@@ -10,6 +10,8 @@
 #include <yt/cpp/mapreduce/interface/error_codes.h>
 #include <yt/cpp/mapreduce/interface/raw_client.h>
 
+#include <yt/yt/core/actions/future.h>
+
 #include <util/datetime/base.h>
 
 #include <util/generic/scope.h>
@@ -166,11 +168,11 @@ void TPingableTransaction::Stop(EStopAction action)
                 });
             break;
         case EStopAction::Abort:
-        NDetail::RequestWithRetry<void>(
-                ClientRetryPolicy_->CreatePolicyForGenericRequest(),
-                [this] (TMutationId& mutationId) {
-                    RawClient_->AbortTransaction(mutationId, TransactionId_);
-                });
+            // Aborting transaction can be called from destructor while unwinding exception stack.
+            // We can't call WaitFor in such conditions (and internally we do it).
+            // So we offload aborting to separate thread.
+            Pinger_->AsyncAbortTransaction(TransactionId_)
+                .BlockingGet();
             break;
         case EStopAction::Detach:
             // Do nothing.