diff options
| author | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-22 18:14:14 +0300 |
|---|---|---|
| committer | hiddenpath <hiddenpath@yandex-team.com> | 2025-01-22 18:33:45 +0300 |
| commit | 781231f99d732831cc11466c47afe0babc6ae203 (patch) | |
| tree | 3c9342691ec43485c11ce56a00118b08e2f1eb75 /yt | |
| parent | 45a4df69199261678034e345d9ae7a93aa08d383 (diff) | |
| download | ydb-781231f99d732831cc11466c47afe0babc6ae203.tar.gz | |
Minor refactorings in request serialization
commit_hash:3882b76fe4391a0a2dd80d40c940ffa250067a58
Diffstat (limited to 'yt')
| -rw-r--r-- | yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp | 2 | ||||
| -rw-r--r-- | yt/cpp/mapreduce/interface/operation.h | 31 |
2 files changed, 27 insertions, 6 deletions
diff --git a/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp index 1a3cee9489..c986e4c025 100644 --- a/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp +++ b/yt/cpp/mapreduce/http_client/rpc_parameters_serialization.cpp @@ -357,7 +357,7 @@ TNode SerializeParamsForListOperations( result["user"] = *options.User_; } if (options.State_) { - result["state"] = *options.State_; + result["state"] = ToString(options.State_); } if (options.Type_) { result["type"] = ToString(*options.Type_); diff --git a/yt/cpp/mapreduce/interface/operation.h b/yt/cpp/mapreduce/interface/operation.h index f541ad2aeb..7da77213d4 100644 --- a/yt/cpp/mapreduce/interface/operation.h +++ b/yt/cpp/mapreduce/interface/operation.h @@ -2389,6 +2389,31 @@ enum class EOperationBriefState : int Failed /* "failed" */, }; + +/// +/// @brief Operation state. +enum class EOperationState : int +{ + None /* "none" */, + Starting /* "starting" */, + Orphaned /* "orphaned" */, + WaitingForAgent /* "waiting_for_agent" */, + Initializing /* "initializing" */, + Preparing /* "preparing" */, + Materializing /* "orphaned" */, + ReviveInitializing /* "revive_initializing" */, + Reviving /* "reviving" */, + RevivingJobs /* "reviving_jobs" */, + Pending /* "pending" */, + Running /* "running" */, + Completing /* "completing" */, + Completed /* "completed" */, + Aborting /* "aborting" */, + Aborted /* "aborted" */, + Failing /* "failing" */, + Failed /* "failed" */, +}; + /// /// @brief Operation type. enum class EOperationType : int @@ -2600,7 +2625,7 @@ struct TListOperationsOptions /// /// @brief Choose operations with given @ref NYT::TOperationAttributes::State. - FLUENT_FIELD_OPTION(TString, State); + FLUENT_FIELD_OPTION(EOperationState, State); /// /// @brief Choose operations with given @ref NYT::TOperationAttributes::Type. @@ -2697,7 +2722,6 @@ enum class EListJobsDataSource : int /// @brief Job type. enum class EJobType : int { - SchedulerFirst /* "scheduler_first" */, Map /* "map" */, PartitionMap /* "partition_map" */, SortedMerge /* "sorted_merge" */, @@ -2715,13 +2739,10 @@ enum class EJobType : int JoinReduce /* "join_reduce" */, Vanilla /* "vanilla" */, SchedulerUnknown /* "scheduler_unknown" */, - SchedulerLast /* "scheduler_last" */, - ReplicatorFirst /* "replicator_first" */, ReplicateChunk /* "replicate_chunk" */, RemoveChunk /* "remove_chunk" */, RepairChunk /* "repair_chunk" */, SealChunk /* "seal_chunk" */, - ReplicatorLast /* "replicator_last" */, }; /// |