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

commit_hash:90bbe36635e0d48c81c153567dcedf28f103efbe

2 files changed, 21 insertions, 0 deletions

diff --git a/yt/cpp/mapreduce/interface/common.cpp b/yt/cpp/mapreduce/interface/common.cpp
index fdb3e66b191..7c54fd65d09 100644
--- a/yt/cpp/mapreduce/interface/common.cpp
+++ b/yt/cpp/mapreduce/interface/common.cpp
@@ -13,6 +13,10 @@
 
 #include <util/generic/xrange.h>
 
+#include <util/datetime/base.h>
+
+#include <util/system/getpid.h>
+
 namespace NYT {
 
 using ::google::protobuf::Descriptor;
@@ -762,6 +766,21 @@ TString ToString(EValueType type)
     ythrow yexception() << "Invalid value type " << static_cast<int>(type);
 }
 
+TMutationId GenerateMutationId()
+{
+    TGUID guid;
+
+    // Some users use `fork()' with yt wrapper
+    // (actually they use python + multiprocessing)
+    // and CreateGuid is not resistant to `fork()', so spice it a little bit.
+    //
+    // Check IGNIETFERRO-610
+    CreateGuid(&guid);
+    guid.dw[2] = GetPID() ^ MicroSeconds();
+
+    return guid;
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 } // namespace NDetail
diff --git a/yt/cpp/mapreduce/interface/common.h b/yt/cpp/mapreduce/interface/common.h
index 7f09fe4c004..d0339f7baf8 100644
--- a/yt/cpp/mapreduce/interface/common.h
+++ b/yt/cpp/mapreduce/interface/common.h
@@ -1402,6 +1402,8 @@ namespace NDetail {
 // TODO: we should use default GENERATE_ENUM_SERIALIZATION
 TString ToString(EValueType type);
 
+TMutationId GenerateMutationId();
+
 } // namespace NDetail
 /// @endcond