YT-26221: Parse control events and save trace info in operations archive

commit_hash:af1a447629e24e0b2fa1e075a45fdc5b5cb16bf4

Author: bystrovserg

yt/cpp/mapreduce/interface/operation.h

@@ -3221,8 +3221,8 @@ struct TJobTraceEvent
     i64 EventIndex = 0;
 
     ///
-    /// @brief Raw evenr in json format.
-    TString Event;
+    /// @brief Raw event in json format.
+    std::string Event;
 
     ///
     /// @brief Time of the event.

yt/cpp/mapreduce/rpc_client/rpc_parameters_serialization.cpp

@@ -786,7 +786,7 @@ NApi::TGetJobTraceOptions SerializeOptionsForGetJobTrace(const TGetJobTraceOptio
         result.JobId = NJobTrackerClient::TJobId(YtGuidFromUtilGuid(*options.JobId_));
     }
     if (options.TraceId_) {
-        result.TraceId = NScheduler::TJobTraceId(YtGuidFromUtilGuid(*options.TraceId_));
+        result.TraceId = NJobTrackerClient::TJobTraceId(YtGuidFromUtilGuid(*options.TraceId_));
     }
     if (options.FromTime_) {
         result.FromTime = *options.FromTime_;

yt/yt/client/api/operation_client.h

@@ -108,7 +108,7 @@ struct TGetJobTraceOptions
     , public TMasterReadOptions
 {
     std::optional<NJobTrackerClient::TJobId> JobId;
-    std::optional<NScheduler::TJobTraceId> TraceId;
+    std::optional<NJobTrackerClient::TJobTraceId> TraceId;
     std::optional<i64> FromTime;
     std::optional<i64> ToTime;
     std::optional<i64> FromEventIndex;
@@ -444,9 +444,9 @@ struct TJobTraceEvent
 {
     NJobTrackerClient::TOperationId OperationId;
     NJobTrackerClient::TJobId JobId;
-    NScheduler::TJobTraceId TraceId;
+    NJobTrackerClient::TJobTraceId TraceId;
     i64 EventIndex;
-    TString Event;
+    std::string Event;
     TInstant EventTime;
 };
 

yt/yt/client/job_tracker_client/public.cpp

@@ -6,6 +6,7 @@ namespace NYT::NJobTrackerClient {
 
 const TJobId NullJobId;
 const TOperationId NullOperationId;
+const TJobTraceId NullJobTraceId;
 
 ////////////////////////////////////////////////////////////////////////////////
 

yt/yt/client/job_tracker_client/public.h

@@ -16,6 +16,10 @@ YT_DEFINE_STRONG_TYPEDEF(TOperationId, TGuid);
 
 extern const TOperationId NullOperationId;
 
+YT_DEFINE_STRONG_TYPEDEF(TJobTraceId, TGuid);
+
+extern const TJobTraceId NullJobTraceId;
+
 ////////////////////////////////////////////////////////////////////////////////
 
 // NB: Please keep the range of values small as this type
@@ -76,4 +80,19 @@ DEFINE_ENUM(EJobState,
 
 ////////////////////////////////////////////////////////////////////////////////
 
+DEFINE_ENUM(EJobTraceEventType,
+    (TraceStarted)
+    (TraceFinished)
+    (TraceDropped)
+);
+
+DEFINE_ENUM(EJobTraceState,
+    (Started)
+    (Finished)
+    (Dropped)
+    (Orphaned)
+);
+
+////////////////////////////////////////////////////////////////////////////////
+
 } // namespace NYT::NJobTrackerClient

yt/yt/client/scheduler/public.h

@@ -16,12 +16,6 @@ class TSpecPatch;
 
 ////////////////////////////////////////////////////////////////////////////////
 
-YT_DEFINE_STRONG_TYPEDEF(TJobTraceId, TGuid);
-
-extern const TJobTraceId NullJobTraceId;
-
-////////////////////////////////////////////////////////////////////////////////
-
 YT_DEFINE_STRONG_TYPEDEF(TAllocationId, TGuid);
 
 extern const TAllocationId NullAllocationId;