diff options
| author | omgronny <omgronny@yandex-team.com> | 2024-06-28 15:07:04 +0300 |
|---|---|---|
| committer | omgronny <omgronny@yandex-team.com> | 2024-06-28 15:19:05 +0300 |
| commit | 1607efc105286defebdf3e768e4a7ff1288bca8c (patch) | |
| tree | 1c1d7ce439f8df06092e775845a078f22cb1a1dc | |
| parent | a75ea2cde045917041437c8859477ba4323503bd (diff) | |
| download | ydb-1607efc105286defebdf3e768e4a7ff1288bca8c.tar.gz | |
YT-21881: Introduce archive_features
dd710438352578a48fdedaf5846f8793bfbabb2d
| -rw-r--r-- | yt/yt/client/api/operation_client.cpp | 1 | ||||
| -rw-r--r-- | yt/yt/client/api/operation_client.h | 1 | ||||
| -rw-r--r-- | yt/yt/client/api/rpc_proxy/helpers.cpp | 8 | ||||
| -rw-r--r-- | yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto | 1 |
4 files changed, 11 insertions, 0 deletions
diff --git a/yt/yt/client/api/operation_client.cpp b/yt/yt/client/api/operation_client.cpp index 30aadc4078..db2ccf3111 100644 --- a/yt/yt/client/api/operation_client.cpp +++ b/yt/yt/client/api/operation_client.cpp @@ -210,6 +210,7 @@ void Serialize(const TJob& job, NYson::IYsonConsumer* consumer, TStringBuf idKey .OptionalItem("monitoring_descriptor", job.MonitoringDescriptor) .OptionalItem("is_stale", job.IsStale) .OptionalItem("job_cookie", job.JobCookie) + .OptionalItem("archive_features", job.ArchiveFeatures) .EndMap(); } diff --git a/yt/yt/client/api/operation_client.h b/yt/yt/client/api/operation_client.h index fa2095cc02..f11a8e63e1 100644 --- a/yt/yt/client/api/operation_client.h +++ b/yt/yt/client/api/operation_client.h @@ -333,6 +333,7 @@ struct TJob std::optional<TString> Pool; std::optional<TString> MonitoringDescriptor; std::optional<ui64> JobCookie; + NYson::TYsonString ArchiveFeatures; std::optional<bool> IsStale; diff --git a/yt/yt/client/api/rpc_proxy/helpers.cpp b/yt/yt/client/api/rpc_proxy/helpers.cpp index c51fe00121..7bb3c7a4cc 100644 --- a/yt/yt/client/api/rpc_proxy/helpers.cpp +++ b/yt/yt/client/api/rpc_proxy/helpers.cpp @@ -947,6 +947,9 @@ void ToProto(NProto::TJob* protoJob, const NApi::TJob& job) if (job.JobCookie) { protoJob->set_job_cookie(*job.JobCookie); } + if (job.ArchiveFeatures) { + protoJob->set_archive_features(job.ArchiveFeatures.ToString()); + } } void FromProto(NApi::TJob* job, const NProto::TJob& protoJob) @@ -1086,6 +1089,11 @@ void FromProto(NApi::TJob* job, const NProto::TJob& protoJob) } else { job->JobCookie.reset(); } + if (protoJob.has_archive_features()) { + job->ArchiveFeatures = TYsonString(protoJob.archive_features()); + } else { + job->ArchiveFeatures = TYsonString(); + } } void ToProto( diff --git a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto index 4c9f0c9ed7..8e7ea8090d 100644 --- a/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto +++ b/yt/yt_proto/yt/client/api/rpc_proxy/proto/api_service.proto @@ -3094,6 +3094,7 @@ message TJob optional NYT.NProto.TGuid probing_job_competition_id = 25; optional bool has_probing_competitors = 26; optional uint64 job_cookie = 27; + optional bytes archive_features = 29; // YSON } message TListJobsStatistics |