1 files changed, 7 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/interface/logging/yt_log.cpp b/yt/cpp/mapreduce/interface/logging/yt_log.cpp
index 1db626adb04..9de369fdcb5 100644
--- a/yt/cpp/mapreduce/interface/logging/yt_log.cpp
+++ b/yt/cpp/mapreduce/interface/logging/yt_log.cpp
@@ -2,10 +2,14 @@
 
 #include "logger.h"
 
+#include <library/cpp/yt/logging/tagged_payload.h>
+
 #include <util/generic/guid.h>
 
 #include <util/system/mutex.h>
 
+#include <variant>
+
 namespace NYT {
 
 using namespace NLogging;
@@ -44,13 +48,14 @@ public:
     void Enqueue(TLogEvent&& event) override
     {
         if (auto logger = GetLogger()) {
+            auto message = GetMessageFromTaggedPayload(std::get<TTaggedLogEventPayload>(event.Payload));
             LogMessage(
                 logger,
                 ToImplLevel(event.Level),
                 ::TSourceLocation(event.SourceFile, event.SourceLine),
                 "%.*s",
-                event.MessageRef.size(),
-                event.MessageRef.begin());
+                message.size(),
+                message.begin());
         } else if (auto* defaultLogManager = GetDefaultLogManager()) {
             defaultLogManager->Enqueue(std::move(event));
         }