diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc
index e528fe7c14..acb4b787d0 100644
--- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc
+++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.cc
@@ -676,41 +676,41 @@ const char descriptor_table_protodef_flyteidl_2fadmin_2fagent_2eproto[] =
"uest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_meta"
"\030\002 \001(\014\"h\n\017GetTaskResponse\022*\n\010resource\030\001 "
"\001(\0132\030.flyteidl.admin.Resource\022)\n\tlog_lin"
- "ks\030\002 \003(\0132\026.flyteidl.core.TaskLog\"\313\001\n\010Res"
- "ource\022$\n\005state\030\001 \001(\0162\025.flyteidl.admin.St"
- "ate\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core.Lit"
- "eralMap\022\017\n\007message\030\003 \001(\t\022)\n\tlog_links\030\004 "
- "\003(\0132\026.flyteidl.core.TaskLog\0221\n\005phase\030\005 \001"
- "(\0162\".flyteidl.core.TaskExecution.Phase\"="
- "\n\021DeleteTaskRequest\022\021\n\ttask_type\030\001 \001(\t\022\025"
- "\n\rresource_meta\030\002 \001(\014\"\024\n\022DeleteTaskRespo"
- "nse\"3\n\005Agent\022\014\n\004name\030\001 \001(\t\022\034\n\024supported_"
- "task_types\030\002 \003(\t\"\037\n\017GetAgentRequest\022\014\n\004n"
- "ame\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005agent\030\001"
- " \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListAgent"
- "sRequest\";\n\022ListAgentsResponse\022%\n\006agents"
- "\030\001 \003(\0132\025.flyteidl.admin.Agent\"\331\001\n\025GetTas"
- "kMetricsRequest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rre"
- "source_meta\030\002 \001(\014\022\017\n\007queries\030\003 \003(\t\022.\n\nst"
- "art_time\030\004 \001(\0132\032.google.protobuf.Timesta"
- "mp\022,\n\010end_time\030\005 \001(\0132\032.google.protobuf.T"
- "imestamp\022\'\n\004step\030\006 \001(\0132\031.google.protobuf"
- ".Duration\"O\n\026GetTaskMetricsResponse\0225\n\007r"
- "esults\030\001 \003(\0132$.flyteidl.core.ExecutionMe"
- "tricResult\"\\\n\022GetTaskLogsRequest\022\021\n\ttask"
- "_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(\014\022\r\n\005li"
- "nes\030\003 \001(\004\022\r\n\005token\030\004 \001(\t\"5\n\023GetTaskLogsR"
- "esponse\022\017\n\007results\030\001 \003(\t\022\r\n\005token\030\002 \001(\t*"
- "^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021PERMA"
- "NENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003"
- "\022\r\n\tSUCCEEDED\020\004B=Z;github.com/flyteorg/f"
- "lyte/flyteidl/gen/pb-go/flyteidl/adminb\006"
- "proto3"
+ "ks\030\002 \003(\0132\026.flyteidl.core.TaskLog\"\317\001\n\010Res"
+ "ource\022(\n\005state\030\001 \001(\0162\025.flyteidl.admin.St"
+ "ateB\002\030\001\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core"
+ ".LiteralMap\022\017\n\007message\030\003 \001(\t\022)\n\tlog_link"
+ "s\030\004 \003(\0132\026.flyteidl.core.TaskLog\0221\n\005phase"
+ "\030\005 \001(\0162\".flyteidl.core.TaskExecution.Pha"
+ "se\"=\n\021DeleteTaskRequest\022\021\n\ttask_type\030\001 \001"
+ "(\t\022\025\n\rresource_meta\030\002 \001(\014\"\024\n\022DeleteTaskR"
+ "esponse\"3\n\005Agent\022\014\n\004name\030\001 \001(\t\022\034\n\024suppor"
+ "ted_task_types\030\002 \003(\t\"\037\n\017GetAgentRequest\022"
+ "\014\n\004name\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005age"
+ "nt\030\001 \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListA"
+ "gentsRequest\";\n\022ListAgentsResponse\022%\n\006ag"
+ "ents\030\001 \003(\0132\025.flyteidl.admin.Agent\"\331\001\n\025Ge"
+ "tTaskMetricsRequest\022\021\n\ttask_type\030\001 \001(\t\022\025"
+ "\n\rresource_meta\030\002 \001(\014\022\017\n\007queries\030\003 \003(\t\022."
+ "\n\nstart_time\030\004 \001(\0132\032.google.protobuf.Tim"
+ "estamp\022,\n\010end_time\030\005 \001(\0132\032.google.protob"
+ "uf.Timestamp\022\'\n\004step\030\006 \001(\0132\031.google.prot"
+ "obuf.Duration\"O\n\026GetTaskMetricsResponse\022"
+ "5\n\007results\030\001 \003(\0132$.flyteidl.core.Executi"
+ "onMetricResult\"\\\n\022GetTaskLogsRequest\022\021\n\t"
+ "task_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(\014\022\r"
+ "\n\005lines\030\003 \001(\004\022\r\n\005token\030\004 \001(\t\"5\n\023GetTaskL"
+ "ogsResponse\022\017\n\007results\030\001 \003(\t\022\r\n\005token\030\002 "
+ "\001(\t*^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021P"
+ "ERMANENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNI"
+ "NG\020\003\022\r\n\tSUCCEEDED\020\004B=Z;github.com/flyteo"
+ "rg/flyte/flyteidl/gen/pb-go/flyteidl/adm"
+ "inb\006proto3"
;
::google::protobuf::internal::DescriptorTable descriptor_table_flyteidl_2fadmin_2fagent_2eproto = {
false, InitDefaults_flyteidl_2fadmin_2fagent_2eproto,
descriptor_table_protodef_flyteidl_2fadmin_2fagent_2eproto,
- "flyteidl/admin/agent.proto", &assign_descriptors_table_flyteidl_2fadmin_2fagent_2eproto, 2406,
+ "flyteidl/admin/agent.proto", &assign_descriptors_table_flyteidl_2fadmin_2fagent_2eproto, 2410,
};
void AddDescriptors_flyteidl_2fadmin_2fagent_2eproto() {
@@ -3531,7 +3531,7 @@ const char* Resource::_InternalParse(const char* begin, const char* end, void* o
ptr = ::google::protobuf::io::Parse32(ptr, &tag);
GOOGLE_PROTOBUF_PARSER_ASSERT(ptr);
switch (tag >> 3) {
- // .flyteidl.admin.State state = 1;
+ // .flyteidl.admin.State state = 1 [deprecated = true];
case 1: {
if (static_cast<::google::protobuf::uint8>(tag) != 8) goto handle_unusual;
::google::protobuf::uint64 val = ::google::protobuf::internal::ReadVarint(&ptr);
@@ -3626,7 +3626,7 @@ bool Resource::MergePartialFromCodedStream(
tag = p.first;
if (!p.second) goto handle_unusual;
switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
- // .flyteidl.admin.State state = 1;
+ // .flyteidl.admin.State state = 1 [deprecated = true];
case 1: {
if (static_cast< ::google::protobuf::uint8>(tag) == (8 & 0xFF)) {
int value = 0;
@@ -3718,7 +3718,7 @@ void Resource::SerializeWithCachedSizes(
::google::protobuf::uint32 cached_has_bits = 0;
(void) cached_has_bits;
- // .flyteidl.admin.State state = 1;
+ // .flyteidl.admin.State state = 1 [deprecated = true];
if (this->state() != 0) {
::google::protobuf::internal::WireFormatLite::WriteEnum(
1, this->state(), output);
@@ -3768,7 +3768,7 @@ ::google::protobuf::uint8* Resource::InternalSerializeWithCachedSizesToArray(
::google::protobuf::uint32 cached_has_bits = 0;
(void) cached_has_bits;
- // .flyteidl.admin.State state = 1;
+ // .flyteidl.admin.State state = 1 [deprecated = true];
if (this->state() != 0) {
target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
1, this->state(), target);
@@ -3852,7 +3852,7 @@ size_t Resource::ByteSizeLong() const {
*outputs_);
}
- // .flyteidl.admin.State state = 1;
+ // .flyteidl.admin.State state = 1 [deprecated = true];
if (this->state() != 0) {
total_size += 1 +
::google::protobuf::internal::WireFormatLite::EnumSize(this->state());
diff --git a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h
index 9116b3743c..4912d899c8 100644
--- a/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h
+++ b/flyteidl/gen/pb-cpp/flyteidl/admin/agent.pb.h
@@ -1133,11 +1133,11 @@ class Resource final :
::flyteidl::core::LiteralMap* mutable_outputs();
void set_allocated_outputs(::flyteidl::core::LiteralMap* outputs);
- // .flyteidl.admin.State state = 1;
- void clear_state();
- static const int kStateFieldNumber = 1;
- ::flyteidl::admin::State state() const;
- void set_state(::flyteidl::admin::State value);
+ // .flyteidl.admin.State state = 1 [deprecated = true];
+ PROTOBUF_DEPRECATED void clear_state();
+ PROTOBUF_DEPRECATED static const int kStateFieldNumber = 1;
+ PROTOBUF_DEPRECATED ::flyteidl::admin::State state() const;
+ PROTOBUF_DEPRECATED void set_state(::flyteidl::admin::State value);
// .flyteidl.core.TaskExecution.Phase phase = 5;
void clear_phase();
@@ -3367,7 +3367,7 @@ GetTaskResponse::log_links() const {
// Resource
-// .flyteidl.admin.State state = 1;
+// .flyteidl.admin.State state = 1 [deprecated = true];
inline void Resource::clear_state() {
state_ = 0;
}
diff --git a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go
index 73eb5e5390..a3f2e327d9 100644
--- a/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go
+++ b/flyteidl/gen/pb-go/flyteidl/admin/agent.pb.go
@@ -399,7 +399,7 @@ func (m *GetTaskResponse) GetLogLinks() []*core.TaskLog {
type Resource struct {
// DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
- State State `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.State" json:"state,omitempty"`
+ State State `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.State" json:"state,omitempty"` // Deprecated: Do not use.
// The outputs of the execution. It's typically used by sql task. Agent service will create a
// Structured dataset pointing to the query result table.
// +optional
@@ -440,6 +440,7 @@ func (m *Resource) XXX_DiscardUnknown() {
var xxx_messageInfo_Resource proto.InternalMessageInfo
+// Deprecated: Do not use.
func (m *Resource) GetState() State {
if m != nil {
return m.State
@@ -1035,75 +1036,76 @@ func init() {
func init() { proto.RegisterFile("flyteidl/admin/agent.proto", fileDescriptor_c434e52bb0028071) }
var fileDescriptor_c434e52bb0028071 = []byte{
- // 1120 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xdf, 0x8f, 0xdb, 0x44,
- 0x10, 0x6e, 0x7e, 0x5e, 0x32, 0xb9, 0x5e, 0x93, 0xed, 0xa5, 0xb8, 0x69, 0x81, 0xca, 0x50, 0x74,
- 0xa2, 0xaa, 0x43, 0xaf, 0x50, 0xae, 0x20, 0x5a, 0xa5, 0x77, 0xa6, 0x3d, 0x29, 0x17, 0x9d, 0xb6,
- 0x39, 0x54, 0x90, 0x20, 0xda, 0x24, 0x73, 0xae, 0x15, 0xc7, 0x76, 0xbd, 0xeb, 0x53, 0x0f, 0xf1,
- 0x04, 0xff, 0x02, 0x0f, 0xfc, 0xa3, 0xbc, 0x23, 0xef, 0xae, 0x9d, 0x38, 0xa4, 0xe5, 0x2a, 0xfa,
- 0xe6, 0x99, 0xf9, 0xe6, 0xdb, 0x6f, 0x67, 0xc6, 0xbb, 0x0b, 0x9d, 0x53, 0xef, 0x5c, 0xa0, 0x3b,
- 0xf5, 0xba, 0x6c, 0x3a, 0x77, 0xfd, 0x2e, 0x73, 0xd0, 0x17, 0x56, 0x18, 0x05, 0x22, 0x20, 0x5b,
- 0x69, 0xcc, 0x92, 0xb1, 0xce, 0xcd, 0x0c, 0x3b, 0x09, 0x22, 0xec, 0x7a, 0xae, 0xc0, 0x88, 0x79,
- 0x5c, 0xa1, 0x3b, 0xd7, 0xf3, 0x51, 0xc1, 0xf8, 0x2c, 0x0d, 0x7d, 0x94, 0x0f, 0xb9, 0x53, 0xf4,
- 0x85, 0x7b, 0xea, 0x62, 0xa4, 0xe3, 0x1f, 0xe6, 0xe3, 0xf8, 0x1a, 0x27, 0xb1, 0x70, 0x03, 0x5f,
- 0x87, 0x6f, 0xe4, 0xc3, 0x73, 0x14, 0x91, 0x3b, 0xc9, 0xb8, 0x9d, 0x20, 0x70, 0x3c, 0xec, 0x4a,
- 0x6b, 0x1c, 0x9f, 0x76, 0xa7, 0x71, 0xc4, 0x96, 0x92, 0x3f, 0x5e, 0x8d, 0x0b, 0x77, 0x8e, 0x5c,
- 0xb0, 0x79, 0xa8, 0x00, 0xe6, 0x5f, 0x15, 0x68, 0x0f, 0x19, 0x9f, 0xd9, 0xe9, 0xaa, 0x47, 0x28,
- 0xd8, 0x94, 0x09, 0x46, 0x28, 0xb4, 0x92, 0x5d, 0x8c, 0x32, 0x3d, 0x23, 0x77, 0x6a, 0x14, 0x6e,
- 0x15, 0x76, 0x1a, 0xbb, 0x9f, 0x59, 0x59, 0x6d, 0x12, 0x4d, 0x56, 0x8e, 0xe0, 0x30, 0xdb, 0x1f,
- 0xbd, 0x22, 0xf2, 0x01, 0x72, 0x13, 0xea, 0x3e, 0x9b, 0x23, 0x0f, 0xd9, 0x04, 0x8d, 0xe2, 0xad,
- 0xc2, 0x4e, 0x9d, 0x2e, 0x1c, 0xe4, 0x10, 0xaa, 0x1e, 0x1b, 0xa3, 0xc7, 0x8d, 0xd2, 0xad, 0xd2,
- 0x4e, 0x63, 0xf7, 0x9e, 0x95, 0x6f, 0x81, 0xb5, 0x56, 0xa8, 0xd5, 0x97, 0x39, 0xb6, 0x2f, 0xa2,
- 0x73, 0xaa, 0x09, 0xc8, 0x0b, 0x68, 0x30, 0xdf, 0x0f, 0x84, 0xac, 0x05, 0x37, 0xca, 0x92, 0xef,
- 0xc1, 0xc5, 0xf8, 0x7a, 0x8b, 0x44, 0x45, 0xba, 0x4c, 0x45, 0x2c, 0xb8, 0x3a, 0xdb, 0xe3, 0x23,
- 0x8e, 0xd1, 0x99, 0x3b, 0xc1, 0x11, 0x9b, 0x4c, 0x82, 0xd8, 0x17, 0x46, 0x45, 0x6e, 0xa6, 0x35,
- 0xdb, 0xe3, 0xcf, 0x55, 0xa4, 0xa7, 0x02, 0x44, 0x40, 0x1b, 0xfd, 0x33, 0x37, 0x0a, 0xfc, 0x39,
- 0xfa, 0x62, 0x74, 0xc6, 0x22, 0x97, 0x8d, 0x3d, 0xe4, 0x46, 0x55, 0x6a, 0x7a, 0x7c, 0x31, 0x4d,
- 0xf6, 0x82, 0xe2, 0x87, 0x94, 0x41, 0x89, 0xdb, 0xc6, 0x35, 0xa1, 0xce, 0x43, 0x68, 0x2c, 0x95,
- 0x85, 0x34, 0xa1, 0x34, 0xc3, 0x73, 0xd9, 0xbd, 0x3a, 0x4d, 0x3e, 0xc9, 0x36, 0x54, 0xce, 0x98,
- 0x17, 0xa7, 0x5d, 0x50, 0xc6, 0x37, 0xc5, 0xbd, 0x42, 0xe7, 0x11, 0x34, 0x57, 0x2b, 0xf0, 0x4e,
- 0xf9, 0x4f, 0xe1, 0xfa, 0x1b, 0xd5, 0xbe, 0x0b, 0x91, 0xf9, 0x47, 0x11, 0x5a, 0xfb, 0x11, 0x32,
- 0x81, 0x49, 0x4d, 0x28, 0xbe, 0x8a, 0x91, 0x0b, 0x72, 0x0f, 0xaa, 0xae, 0x1f, 0xc6, 0x82, 0xeb,
- 0x59, 0xbc, 0xbe, 0x32, 0x8b, 0x7d, 0xf5, 0x5f, 0x1e, 0xb1, 0x90, 0x6a, 0x20, 0xf9, 0x1a, 0x6a,
- 0x02, 0xe7, 0xa1, 0xc7, 0x84, 0x5a, 0xa5, 0xb1, 0x7b, 0x63, 0xcd, 0x00, 0x0f, 0x35, 0x84, 0x66,
- 0x60, 0xf2, 0x09, 0x5c, 0x0e, 0x62, 0x11, 0xc6, 0x62, 0x14, 0x46, 0x78, 0xea, 0xbe, 0x36, 0x4a,
- 0x52, 0xe3, 0xa6, 0x72, 0x1e, 0x4b, 0x1f, 0xf9, 0x19, 0x3e, 0x58, 0xf9, 0x4f, 0xe6, 0xba, 0x6b,
- 0x46, 0x59, 0x2e, 0x76, 0xfb, 0x42, 0x2d, 0xa6, 0x6d, 0xb1, 0xce, 0x6d, 0xfe, 0x0a, 0x64, 0xb9,
- 0x08, 0x3c, 0x0c, 0x7c, 0x8e, 0xe4, 0x36, 0x5c, 0x8e, 0x90, 0x07, 0x71, 0x34, 0x41, 0xb9, 0x9c,
- 0x2c, 0xc6, 0xe6, 0xb3, 0x4b, 0x74, 0x33, 0x75, 0x27, 0x04, 0xe4, 0x01, 0xd4, 0x52, 0x5b, 0xef,
- 0xdc, 0x58, 0x15, 0x43, 0x75, 0xfc, 0xd9, 0x25, 0x9a, 0x61, 0x9f, 0x54, 0xa0, 0x14, 0x21, 0x37,
- 0x29, 0x6c, 0x3d, 0x45, 0xb1, 0x5c, 0xfd, 0x1b, 0x50, 0x97, 0x9b, 0x15, 0xe7, 0x21, 0xea, 0x2e,
- 0xd6, 0x12, 0xc7, 0xf0, 0x3c, 0x94, 0xe5, 0xca, 0x8b, 0x4a, 0x96, 0xdc, 0xcc, 0x4b, 0x32, 0x7f,
- 0x83, 0x2b, 0x19, 0xa7, 0xde, 0xcc, 0x97, 0x4b, 0x2a, 0x0b, 0x6f, 0x57, 0xb9, 0xd0, 0x48, 0xee,
- 0x43, 0xdd, 0x0b, 0x9c, 0x91, 0xe7, 0xfa, 0x33, 0x6e, 0x14, 0xe5, 0xcf, 0x74, 0x6d, 0x4d, 0x5b,
- 0xfb, 0x81, 0x43, 0x6b, 0x5e, 0xe0, 0xf4, 0x13, 0x9c, 0xf9, 0x77, 0x01, 0x6a, 0x29, 0x17, 0xb9,
- 0x03, 0x15, 0x2e, 0x92, 0xa1, 0x48, 0x16, 0xdd, 0xda, 0x6d, 0xaf, 0x2e, 0xfa, 0x3c, 0x09, 0x52,
- 0x85, 0x21, 0xf7, 0x61, 0x43, 0xb5, 0x9d, 0xeb, 0x4a, 0xbe, 0x65, 0xf0, 0x52, 0x24, 0x31, 0x60,
- 0x63, 0x8e, 0x9c, 0x33, 0x07, 0xf5, 0xe8, 0xa4, 0x66, 0x5e, 0x7d, 0xf9, 0x62, 0xea, 0xc9, 0x1e,
- 0x54, 0xc2, 0x97, 0x8c, 0xa3, 0x3c, 0x6d, 0xb6, 0x76, 0xcd, 0xb7, 0x1d, 0xc3, 0xd6, 0x71, 0x82,
- 0xa4, 0x2a, 0xc1, 0x3c, 0x81, 0xd6, 0x01, 0x7a, 0x98, 0xff, 0x95, 0xfe, 0x7f, 0x33, 0xb7, 0x81,
- 0x2c, 0xd3, 0xaa, 0x7e, 0x9a, 0x47, 0x50, 0xe9, 0x25, 0x17, 0x29, 0x21, 0x50, 0x4e, 0x4e, 0x77,
- 0xcd, 0x2d, 0xbf, 0xc9, 0x17, 0xb0, 0xcd, 0xe3, 0x30, 0x0c, 0x22, 0x81, 0xd3, 0x51, 0xb6, 0xbc,
- 0xea, 0x60, 0x9d, 0x92, 0x2c, 0x36, 0xd4, 0x42, 0xb8, 0x79, 0x5b, 0x4e, 0x8c, 0x64, 0x4c, 0x95,
- 0xaf, 0x21, 0x36, 0x1f, 0x43, 0x73, 0x01, 0xd3, 0x93, 0x75, 0x07, 0x2a, 0xf2, 0x4a, 0xd7, 0x63,
- 0xf5, 0xaf, 0x0e, 0x2b, 0xb4, 0xc2, 0x98, 0x57, 0xa1, 0xd5, 0x77, 0xb9, 0x62, 0xe0, 0x7a, 0x25,
- 0x73, 0x1f, 0xc8, 0xb2, 0x53, 0xf3, 0xde, 0x85, 0xaa, 0xcc, 0x49, 0x0e, 0xa1, 0xd2, 0x9b, 0x89,
- 0x35, 0xc8, 0xfc, 0xb3, 0x08, 0x6d, 0x3d, 0xf4, 0x47, 0xea, 0xfa, 0x7e, 0x6f, 0x2d, 0x48, 0x46,
- 0xec, 0x55, 0x8c, 0x91, 0x8b, 0xea, 0xd6, 0xac, 0xd3, 0xd4, 0x24, 0x0f, 0x01, 0xb8, 0x60, 0x91,
- 0x18, 0x25, 0x77, 0xbe, 0x3e, 0x8b, 0x3a, 0x96, 0x7a, 0x10, 0x58, 0xe9, 0x83, 0xc0, 0x1a, 0xa6,
- 0x0f, 0x02, 0x5a, 0x97, 0xe8, 0xc4, 0x26, 0x5f, 0x41, 0x0d, 0xfd, 0xa9, 0x4a, 0xac, 0xfc, 0x67,
- 0xe2, 0x06, 0xfa, 0x53, 0x99, 0x76, 0x17, 0xca, 0x5c, 0x60, 0x68, 0x54, 0xf5, 0x0f, 0xb2, 0x9a,
- 0x72, 0xa0, 0x1f, 0x27, 0x54, 0xc2, 0xcc, 0x17, 0x70, 0x6d, 0xb5, 0x2a, 0xba, 0xbe, 0x8f, 0x60,
- 0x23, 0x42, 0x1e, 0x7b, 0x59, 0x81, 0x3f, 0x5d, 0x19, 0xf5, 0xe5, 0x73, 0x32, 0x72, 0x27, 0x54,
- 0x82, 0x69, 0x9a, 0x64, 0xfe, 0x5e, 0x00, 0xa2, 0xa9, 0xfb, 0x81, 0xf3, 0x1e, 0xab, 0xbd, 0x0d,
- 0x15, 0xcf, 0xf5, 0x65, 0xad, 0x0b, 0x3b, 0x65, 0xaa, 0x8c, 0xc4, 0x2b, 0x82, 0x19, 0xfa, 0xb2,
- 0xc8, 0x75, 0xaa, 0x0c, 0xd3, 0x86, 0xab, 0x39, 0x0d, 0x7a, 0x6f, 0x46, 0x7e, 0x6f, 0xf5, 0x4c,
- 0xf5, 0x82, 0xa6, 0xb8, 0x44, 0xf3, 0xf9, 0x2f, 0x50, 0x91, 0x07, 0x11, 0x69, 0x43, 0x8b, 0xda,
- 0x43, 0xfa, 0x63, 0xef, 0x49, 0xdf, 0x1e, 0x7d, 0xdf, 0x3b, 0xec, 0x9f, 0x50, 0xbb, 0x79, 0x29,
- 0x71, 0x1f, 0xdb, 0xf4, 0xa8, 0x37, 0xb0, 0x07, 0xc3, 0xcc, 0x5d, 0x20, 0x0d, 0xd8, 0x38, 0xb6,
- 0x07, 0x07, 0x87, 0x83, 0xa7, 0xcd, 0x62, 0x62, 0xd0, 0x93, 0xc1, 0x20, 0x31, 0x4a, 0xe4, 0x32,
- 0xd4, 0x9f, 0x9f, 0xec, 0xef, 0xdb, 0xf6, 0x81, 0x7d, 0xd0, 0x2c, 0x3f, 0xf9, 0xee, 0xa7, 0x6f,
- 0x1d, 0x57, 0xbc, 0x8c, 0xc7, 0xd6, 0x24, 0x98, 0x77, 0x65, 0x99, 0x83, 0xc8, 0x51, 0x1f, 0xdd,
- 0xec, 0xed, 0xe9, 0xa0, 0xdf, 0x0d, 0xc7, 0x77, 0x9d, 0xa0, 0x9b, 0x7f, 0x32, 0x8f, 0xab, 0xb2,
- 0xbb, 0xf7, 0xff, 0x09, 0x00, 0x00, 0xff, 0xff, 0x27, 0x1f, 0x64, 0x1a, 0x4b, 0x0b, 0x00, 0x00,
+ // 1123 bytes of a gzipped FileDescriptorProto
+ 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xef, 0x6f, 0xdb, 0xc4,
+ 0x1b, 0x5f, 0x7e, 0x36, 0x79, 0xd2, 0x75, 0xc9, 0xad, 0xd9, 0xd7, 0xcb, 0xf6, 0x85, 0xc9, 0x30,
+ 0x54, 0x81, 0xe6, 0xb0, 0x0e, 0x46, 0x07, 0x62, 0x53, 0xda, 0x9a, 0xad, 0x52, 0x1a, 0x55, 0xb7,
+ 0x14, 0x0d, 0x24, 0x88, 0x2e, 0xc9, 0x53, 0xcf, 0x8a, 0x63, 0x7b, 0xbe, 0x73, 0xb5, 0x22, 0x5e,
+ 0xc1, 0xbf, 0xc0, 0x0b, 0xfe, 0x55, 0xde, 0x21, 0xdf, 0x9d, 0x9d, 0x38, 0x64, 0xa3, 0x13, 0x7b,
+ 0xe7, 0xe7, 0xd7, 0xe7, 0xf9, 0x3c, 0x3f, 0x7c, 0x77, 0xd0, 0x39, 0xf3, 0x2e, 0x04, 0xba, 0x53,
+ 0xaf, 0xcb, 0xa6, 0x73, 0xd7, 0xef, 0x32, 0x07, 0x7d, 0x61, 0x85, 0x51, 0x20, 0x02, 0xb2, 0x95,
+ 0xda, 0x2c, 0x69, 0xeb, 0xdc, 0xce, 0x7c, 0x27, 0x41, 0x84, 0x5d, 0xcf, 0x15, 0x18, 0x31, 0x8f,
+ 0x2b, 0xef, 0xce, 0xcd, 0xbc, 0x55, 0x30, 0x3e, 0x4b, 0x4d, 0x1f, 0xe4, 0x4d, 0xee, 0x14, 0x7d,
+ 0xe1, 0x9e, 0xb9, 0x18, 0x69, 0xfb, 0xff, 0xf3, 0x76, 0x7c, 0x8d, 0x93, 0x58, 0xb8, 0x81, 0xaf,
+ 0xcd, 0xb7, 0xf2, 0xe6, 0x39, 0x8a, 0xc8, 0x9d, 0x64, 0xd8, 0x4e, 0x10, 0x38, 0x1e, 0x76, 0xa5,
+ 0x34, 0x8e, 0xcf, 0xba, 0xd3, 0x38, 0x62, 0x4b, 0xc1, 0x1f, 0xae, 0xda, 0x85, 0x3b, 0x47, 0x2e,
+ 0xd8, 0x3c, 0x54, 0x0e, 0xe6, 0x9f, 0x15, 0x68, 0x0f, 0x19, 0x9f, 0xd9, 0x69, 0xd6, 0x63, 0x14,
+ 0x6c, 0xca, 0x04, 0x23, 0x14, 0x5a, 0x49, 0x15, 0xa3, 0x8c, 0xcf, 0xc8, 0x9d, 0x1a, 0x85, 0x3b,
+ 0x85, 0x9d, 0xc6, 0xee, 0x27, 0x56, 0xd6, 0x9b, 0x84, 0x93, 0x95, 0x03, 0x38, 0xca, 0xea, 0xa3,
+ 0xd7, 0x44, 0xde, 0x40, 0x6e, 0x43, 0xdd, 0x67, 0x73, 0xe4, 0x21, 0x9b, 0xa0, 0x51, 0xbc, 0x53,
+ 0xd8, 0xa9, 0xd3, 0x85, 0x82, 0x1c, 0x41, 0xd5, 0x63, 0x63, 0xf4, 0xb8, 0x51, 0xba, 0x53, 0xda,
+ 0x69, 0xec, 0xde, 0xb7, 0xf2, 0x23, 0xb0, 0xd6, 0x12, 0xb5, 0xfa, 0x32, 0xc6, 0xf6, 0x45, 0x74,
+ 0x41, 0x35, 0x00, 0x79, 0x01, 0x0d, 0xe6, 0xfb, 0x81, 0x90, 0xbd, 0xe0, 0x46, 0x59, 0xe2, 0x3d,
+ 0xbc, 0x1c, 0x5e, 0x6f, 0x11, 0xa8, 0x40, 0x97, 0xa1, 0x88, 0x05, 0xd7, 0x67, 0x7b, 0x7c, 0xc4,
+ 0x31, 0x3a, 0x77, 0x27, 0x38, 0x62, 0x93, 0x49, 0x10, 0xfb, 0xc2, 0xa8, 0xc8, 0x62, 0x5a, 0xb3,
+ 0x3d, 0xfe, 0x5c, 0x59, 0x7a, 0xca, 0x40, 0x04, 0xb4, 0xd1, 0x3f, 0x77, 0xa3, 0xc0, 0x9f, 0xa3,
+ 0x2f, 0x46, 0xe7, 0x2c, 0x72, 0xd9, 0xd8, 0x43, 0x6e, 0x54, 0x25, 0xa7, 0x27, 0x97, 0xe3, 0x64,
+ 0x2f, 0x20, 0xbe, 0x4f, 0x11, 0x14, 0xb9, 0x6d, 0x5c, 0x63, 0xea, 0x3c, 0x82, 0xc6, 0x52, 0x5b,
+ 0x48, 0x13, 0x4a, 0x33, 0xbc, 0x90, 0xd3, 0xab, 0xd3, 0xe4, 0x93, 0x6c, 0x43, 0xe5, 0x9c, 0x79,
+ 0x71, 0x3a, 0x05, 0x25, 0x7c, 0x5d, 0xdc, 0x2b, 0x74, 0x1e, 0x43, 0x73, 0xb5, 0x03, 0xef, 0x14,
+ 0xff, 0x14, 0x6e, 0xbe, 0x91, 0xed, 0xbb, 0x00, 0x99, 0xbf, 0x17, 0xa1, 0x75, 0x10, 0x21, 0x13,
+ 0x98, 0xf4, 0x84, 0xe2, 0xab, 0x18, 0xb9, 0x20, 0xf7, 0xa1, 0xea, 0xfa, 0x61, 0x2c, 0xb8, 0xde,
+ 0xc5, 0x9b, 0x2b, 0xbb, 0xd8, 0x57, 0xff, 0xe5, 0x31, 0x0b, 0xa9, 0x76, 0x24, 0x5f, 0x41, 0x4d,
+ 0xe0, 0x3c, 0xf4, 0x98, 0x50, 0x59, 0x1a, 0xbb, 0xb7, 0xd6, 0x2c, 0xf0, 0x50, 0xbb, 0xd0, 0xcc,
+ 0x99, 0x7c, 0x04, 0x57, 0x83, 0x58, 0x84, 0xb1, 0x18, 0x85, 0x11, 0x9e, 0xb9, 0xaf, 0x8d, 0x92,
+ 0xe4, 0xb8, 0xa9, 0x94, 0x27, 0x52, 0x47, 0x7e, 0x82, 0xff, 0xad, 0xfc, 0x27, 0x73, 0x3d, 0x35,
+ 0xa3, 0x2c, 0x93, 0xdd, 0xbd, 0xd4, 0x88, 0x69, 0x5b, 0xac, 0x53, 0x9b, 0xbf, 0x00, 0x59, 0x6e,
+ 0x02, 0x0f, 0x03, 0x9f, 0x23, 0xb9, 0x0b, 0x57, 0x23, 0xe4, 0x41, 0x1c, 0x4d, 0x50, 0xa6, 0x93,
+ 0xcd, 0xd8, 0x7c, 0x76, 0x85, 0x6e, 0xa6, 0xea, 0x04, 0x80, 0x3c, 0x84, 0x5a, 0x2a, 0xeb, 0xca,
+ 0x8d, 0x55, 0x32, 0x54, 0xdb, 0x9f, 0x5d, 0xa1, 0x99, 0xef, 0x7e, 0x05, 0x4a, 0x11, 0x72, 0x93,
+ 0xc2, 0xd6, 0x53, 0x14, 0xcb, 0xdd, 0xbf, 0x05, 0x75, 0x59, 0xac, 0xb8, 0x08, 0x51, 0x4f, 0xb1,
+ 0x96, 0x28, 0x86, 0x17, 0xa1, 0x6c, 0x57, 0x9e, 0x54, 0x92, 0x72, 0x33, 0x4f, 0xc9, 0xfc, 0x15,
+ 0xae, 0x65, 0x98, 0xba, 0x98, 0x2f, 0x96, 0x58, 0x16, 0xde, 0xce, 0x72, 0xc1, 0x91, 0x3c, 0x80,
+ 0xba, 0x17, 0x38, 0x23, 0xcf, 0xf5, 0x67, 0xdc, 0x28, 0xca, 0x9f, 0xe9, 0xc6, 0x9a, 0xb1, 0xf6,
+ 0x03, 0x87, 0xd6, 0xbc, 0xc0, 0xe9, 0x27, 0x7e, 0xe6, 0x5f, 0x05, 0xa8, 0xa5, 0x58, 0xa4, 0x0b,
+ 0x15, 0x2e, 0x92, 0xa5, 0x48, 0x92, 0x6e, 0xed, 0xb6, 0x57, 0x93, 0x3e, 0x4f, 0x8c, 0xfb, 0x45,
+ 0xa3, 0x40, 0x95, 0x1f, 0x79, 0x00, 0x1b, 0x6a, 0xf4, 0x5c, 0x77, 0xf3, 0x2d, 0xcb, 0x97, 0x7a,
+ 0x12, 0x03, 0x36, 0xe6, 0xc8, 0x39, 0x73, 0x50, 0xaf, 0x4f, 0x2a, 0xe6, 0x2b, 0x28, 0x5f, 0xae,
+ 0x02, 0xb2, 0x07, 0x95, 0xf0, 0x25, 0xe3, 0x28, 0x4f, 0x9c, 0xad, 0x5d, 0xf3, 0x6d, 0x47, 0xb1,
+ 0x75, 0x92, 0x78, 0x52, 0x15, 0x60, 0x9e, 0x42, 0xeb, 0x10, 0x3d, 0xcc, 0xff, 0x4e, 0xff, 0x7d,
+ 0xa0, 0xdb, 0x40, 0x96, 0x61, 0xd5, 0x4c, 0xcd, 0x63, 0xa8, 0xf4, 0x92, 0xcb, 0x94, 0x10, 0x28,
+ 0x27, 0x27, 0xbc, 0xc6, 0x96, 0xdf, 0xe4, 0x73, 0xd8, 0xe6, 0x71, 0x18, 0x06, 0x91, 0xc0, 0xe9,
+ 0x28, 0x4b, 0xaf, 0xa6, 0x58, 0xa7, 0x24, 0xb3, 0x0d, 0x35, 0x11, 0x6e, 0xde, 0x95, 0x5b, 0x23,
+ 0x11, 0x53, 0xe6, 0x6b, 0x80, 0xcd, 0x27, 0xd0, 0x5c, 0xb8, 0xe9, 0xed, 0xfa, 0x0c, 0x2a, 0xf2,
+ 0x5a, 0xd7, 0xab, 0xf5, 0x8f, 0x29, 0x2b, 0x6f, 0xe5, 0x63, 0x5e, 0x87, 0x56, 0xdf, 0xe5, 0x0a,
+ 0x81, 0xeb, 0x4c, 0xe6, 0x01, 0x90, 0x65, 0xa5, 0xc6, 0xbd, 0x07, 0x55, 0x19, 0x93, 0x1c, 0x44,
+ 0xa5, 0x37, 0x03, 0x6b, 0x27, 0xf3, 0x8f, 0x22, 0xb4, 0xf5, 0xe2, 0x1f, 0xab, 0x2b, 0xfc, 0xbd,
+ 0x8d, 0x20, 0x59, 0xb1, 0x57, 0x31, 0x46, 0x2e, 0xaa, 0x9b, 0xb3, 0x4e, 0x53, 0x91, 0x3c, 0x02,
+ 0xe0, 0x82, 0x45, 0x62, 0x94, 0xdc, 0xfb, 0xfa, 0x3c, 0xea, 0x58, 0xea, 0x51, 0x60, 0xa5, 0x8f,
+ 0x02, 0x6b, 0x98, 0x3e, 0x0a, 0x68, 0x5d, 0x7a, 0x27, 0x32, 0xf9, 0x12, 0x6a, 0xe8, 0x4f, 0x55,
+ 0x60, 0xe5, 0x5f, 0x03, 0x37, 0xd0, 0x9f, 0xca, 0xb0, 0x7b, 0x50, 0xe6, 0x02, 0x43, 0xa3, 0xaa,
+ 0x7f, 0x90, 0xd5, 0x90, 0x43, 0xfd, 0x40, 0xa1, 0xd2, 0xcd, 0x7c, 0x01, 0x37, 0x56, 0xbb, 0xa2,
+ 0xfb, 0xfb, 0x18, 0x36, 0x22, 0xe4, 0xb1, 0x97, 0x35, 0xf8, 0xe3, 0x95, 0x55, 0x5f, 0x3e, 0x2b,
+ 0x23, 0x77, 0x42, 0xa5, 0x33, 0x4d, 0x83, 0xcc, 0xdf, 0x0a, 0x40, 0x34, 0x74, 0x3f, 0x70, 0xde,
+ 0x63, 0xb7, 0xb7, 0xa1, 0xe2, 0xb9, 0xbe, 0xec, 0x75, 0x61, 0xa7, 0x4c, 0x95, 0x90, 0x68, 0x45,
+ 0x30, 0x43, 0x5f, 0x36, 0xb9, 0x4e, 0x95, 0x60, 0xda, 0x70, 0x3d, 0xc7, 0x41, 0xd7, 0x66, 0xe4,
+ 0x6b, 0xab, 0x67, 0xac, 0x17, 0x30, 0xc5, 0x25, 0x98, 0x4f, 0x7f, 0x86, 0x8a, 0x3c, 0x8c, 0x48,
+ 0x1b, 0x5a, 0xd4, 0x1e, 0xd2, 0x1f, 0x7a, 0xfb, 0x7d, 0x7b, 0xf4, 0x5d, 0xef, 0xa8, 0x7f, 0x4a,
+ 0xed, 0xe6, 0x95, 0x44, 0x7d, 0x62, 0xd3, 0xe3, 0xde, 0xc0, 0x1e, 0x0c, 0x33, 0x75, 0x81, 0x34,
+ 0x60, 0xe3, 0xc4, 0x1e, 0x1c, 0x1e, 0x0d, 0x9e, 0x36, 0x8b, 0x89, 0x40, 0x4f, 0x07, 0x83, 0x44,
+ 0x28, 0x91, 0xab, 0x50, 0x7f, 0x7e, 0x7a, 0x70, 0x60, 0xdb, 0x87, 0xf6, 0x61, 0xb3, 0xbc, 0xff,
+ 0xed, 0x8f, 0xdf, 0x38, 0xae, 0x78, 0x19, 0x8f, 0xad, 0x49, 0x30, 0xef, 0xca, 0x36, 0x07, 0x91,
+ 0xa3, 0x3e, 0xba, 0xd9, 0xfb, 0xd3, 0x41, 0xbf, 0x1b, 0x8e, 0xef, 0x39, 0x41, 0x37, 0xff, 0x6c,
+ 0x1e, 0x57, 0xe5, 0x74, 0x1f, 0xfc, 0x1d, 0x00, 0x00, 0xff, 0xff, 0xf2, 0xd1, 0x03, 0x06, 0x4f,
+ 0x0b, 0x00, 0x00,
}
diff --git a/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java b/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java
index 154ebfc418..e5422d0656 100644
--- a/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java
+++ b/flyteidl/gen/pb-java/flyteidl/admin/AgentOuterClass.java
@@ -6181,17 +6181,17 @@ public interface ResourceOrBuilder extends
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- int getStateValue();
+ @java.lang.Deprecated int getStateValue();
/**
*
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- flyteidl.admin.AgentOuterClass.State getState();
+ @java.lang.Deprecated flyteidl.admin.AgentOuterClass.State getState();
/**
*
@@ -6429,9 +6429,9 @@ private Resource(
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public int getStateValue() {
+ @java.lang.Deprecated public int getStateValue() {
return state_;
}
/**
@@ -6439,9 +6439,9 @@ public int getStateValue() {
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public flyteidl.admin.AgentOuterClass.State getState() {
+ @java.lang.Deprecated public flyteidl.admin.AgentOuterClass.State getState() {
@SuppressWarnings("deprecation")
flyteidl.admin.AgentOuterClass.State result = flyteidl.admin.AgentOuterClass.State.valueOf(state_);
return result == null ? flyteidl.admin.AgentOuterClass.State.UNRECOGNIZED : result;
@@ -7037,9 +7037,9 @@ public Builder mergeFrom(
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public int getStateValue() {
+ @java.lang.Deprecated public int getStateValue() {
return state_;
}
/**
@@ -7047,9 +7047,9 @@ public int getStateValue() {
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public Builder setStateValue(int value) {
+ @java.lang.Deprecated public Builder setStateValue(int value) {
state_ = value;
onChanged();
return this;
@@ -7059,9 +7059,9 @@ public Builder setStateValue(int value) {
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public flyteidl.admin.AgentOuterClass.State getState() {
+ @java.lang.Deprecated public flyteidl.admin.AgentOuterClass.State getState() {
@SuppressWarnings("deprecation")
flyteidl.admin.AgentOuterClass.State result = flyteidl.admin.AgentOuterClass.State.valueOf(state_);
return result == null ? flyteidl.admin.AgentOuterClass.State.UNRECOGNIZED : result;
@@ -7071,9 +7071,9 @@ public flyteidl.admin.AgentOuterClass.State getState() {
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public Builder setState(flyteidl.admin.AgentOuterClass.State value) {
+ @java.lang.Deprecated public Builder setState(flyteidl.admin.AgentOuterClass.State value) {
if (value == null) {
throw new NullPointerException();
}
@@ -7087,9 +7087,9 @@ public Builder setState(flyteidl.admin.AgentOuterClass.State value) {
* DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
*
*
- * .flyteidl.admin.State state = 1;
+ * .flyteidl.admin.State state = 1 [deprecated = true];
*/
- public Builder clearState() {
+ @java.lang.Deprecated public Builder clearState() {
state_ = 0;
onChanged();
@@ -16722,36 +16722,36 @@ public flyteidl.admin.AgentOuterClass.GetTaskLogsResponse getDefaultInstanceForT
"uest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rresource_meta" +
"\030\002 \001(\014\"h\n\017GetTaskResponse\022*\n\010resource\030\001 " +
"\001(\0132\030.flyteidl.admin.Resource\022)\n\tlog_lin" +
- "ks\030\002 \003(\0132\026.flyteidl.core.TaskLog\"\313\001\n\010Res" +
- "ource\022$\n\005state\030\001 \001(\0162\025.flyteidl.admin.St" +
- "ate\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core.Lit" +
- "eralMap\022\017\n\007message\030\003 \001(\t\022)\n\tlog_links\030\004 " +
- "\003(\0132\026.flyteidl.core.TaskLog\0221\n\005phase\030\005 \001" +
- "(\0162\".flyteidl.core.TaskExecution.Phase\"=" +
- "\n\021DeleteTaskRequest\022\021\n\ttask_type\030\001 \001(\t\022\025" +
- "\n\rresource_meta\030\002 \001(\014\"\024\n\022DeleteTaskRespo" +
- "nse\"3\n\005Agent\022\014\n\004name\030\001 \001(\t\022\034\n\024supported_" +
- "task_types\030\002 \003(\t\"\037\n\017GetAgentRequest\022\014\n\004n" +
- "ame\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005agent\030\001" +
- " \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListAgent" +
- "sRequest\";\n\022ListAgentsResponse\022%\n\006agents" +
- "\030\001 \003(\0132\025.flyteidl.admin.Agent\"\331\001\n\025GetTas" +
- "kMetricsRequest\022\021\n\ttask_type\030\001 \001(\t\022\025\n\rre" +
- "source_meta\030\002 \001(\014\022\017\n\007queries\030\003 \003(\t\022.\n\nst" +
- "art_time\030\004 \001(\0132\032.google.protobuf.Timesta" +
- "mp\022,\n\010end_time\030\005 \001(\0132\032.google.protobuf.T" +
- "imestamp\022\'\n\004step\030\006 \001(\0132\031.google.protobuf" +
- ".Duration\"O\n\026GetTaskMetricsResponse\0225\n\007r" +
- "esults\030\001 \003(\0132$.flyteidl.core.ExecutionMe" +
- "tricResult\"\\\n\022GetTaskLogsRequest\022\021\n\ttask" +
- "_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(\014\022\r\n\005li" +
- "nes\030\003 \001(\004\022\r\n\005token\030\004 \001(\t\"5\n\023GetTaskLogsR" +
- "esponse\022\017\n\007results\030\001 \003(\t\022\r\n\005token\030\002 \001(\t*" +
- "^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021PERMA" +
- "NENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNING\020\003" +
- "\022\r\n\tSUCCEEDED\020\004B=Z;github.com/flyteorg/f" +
- "lyte/flyteidl/gen/pb-go/flyteidl/adminb\006" +
- "proto3"
+ "ks\030\002 \003(\0132\026.flyteidl.core.TaskLog\"\317\001\n\010Res" +
+ "ource\022(\n\005state\030\001 \001(\0162\025.flyteidl.admin.St" +
+ "ateB\002\030\001\022*\n\007outputs\030\002 \001(\0132\031.flyteidl.core" +
+ ".LiteralMap\022\017\n\007message\030\003 \001(\t\022)\n\tlog_link" +
+ "s\030\004 \003(\0132\026.flyteidl.core.TaskLog\0221\n\005phase" +
+ "\030\005 \001(\0162\".flyteidl.core.TaskExecution.Pha" +
+ "se\"=\n\021DeleteTaskRequest\022\021\n\ttask_type\030\001 \001" +
+ "(\t\022\025\n\rresource_meta\030\002 \001(\014\"\024\n\022DeleteTaskR" +
+ "esponse\"3\n\005Agent\022\014\n\004name\030\001 \001(\t\022\034\n\024suppor" +
+ "ted_task_types\030\002 \003(\t\"\037\n\017GetAgentRequest\022" +
+ "\014\n\004name\030\001 \001(\t\"8\n\020GetAgentResponse\022$\n\005age" +
+ "nt\030\001 \001(\0132\025.flyteidl.admin.Agent\"\023\n\021ListA" +
+ "gentsRequest\";\n\022ListAgentsResponse\022%\n\006ag" +
+ "ents\030\001 \003(\0132\025.flyteidl.admin.Agent\"\331\001\n\025Ge" +
+ "tTaskMetricsRequest\022\021\n\ttask_type\030\001 \001(\t\022\025" +
+ "\n\rresource_meta\030\002 \001(\014\022\017\n\007queries\030\003 \003(\t\022." +
+ "\n\nstart_time\030\004 \001(\0132\032.google.protobuf.Tim" +
+ "estamp\022,\n\010end_time\030\005 \001(\0132\032.google.protob" +
+ "uf.Timestamp\022\'\n\004step\030\006 \001(\0132\031.google.prot" +
+ "obuf.Duration\"O\n\026GetTaskMetricsResponse\022" +
+ "5\n\007results\030\001 \003(\0132$.flyteidl.core.Executi" +
+ "onMetricResult\"\\\n\022GetTaskLogsRequest\022\021\n\t" +
+ "task_type\030\001 \001(\t\022\025\n\rresource_meta\030\002 \001(\014\022\r" +
+ "\n\005lines\030\003 \001(\004\022\r\n\005token\030\004 \001(\t\"5\n\023GetTaskL" +
+ "ogsResponse\022\017\n\007results\030\001 \003(\t\022\r\n\005token\030\002 " +
+ "\001(\t*^\n\005State\022\025\n\021RETRYABLE_FAILURE\020\000\022\025\n\021P" +
+ "ERMANENT_FAILURE\020\001\022\013\n\007PENDING\020\002\022\013\n\007RUNNI" +
+ "NG\020\003\022\r\n\tSUCCEEDED\020\004B=Z;github.com/flyteo" +
+ "rg/flyte/flyteidl/gen/pb-go/flyteidl/adm" +
+ "inb\006proto3"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {
diff --git a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py
index 81e254399e..f23ad50819 100644
--- a/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py
+++ b/flyteidl/gen/pb_python/flyteidl/admin/agent_pb2.py
@@ -20,7 +20,7 @@
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1a\x66lyteidl/admin/agent.proto\x12\x0e\x66lyteidl.admin\x1a\x1c\x66lyteidl/core/literals.proto\x1a\x19\x66lyteidl/core/tasks.proto\x1a\x1e\x66lyteidl/core/identifier.proto\x1a\x1d\x66lyteidl/core/execution.proto\x1a\x1b\x66lyteidl/core/metrics.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\x98\x05\n\x15TaskExecutionMetadata\x12R\n\x11task_execution_id\x18\x01 \x01(\x0b\x32&.flyteidl.core.TaskExecutionIdentifierR\x0ftaskExecutionId\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12I\n\x06labels\x18\x03 \x03(\x0b\x32\x31.flyteidl.admin.TaskExecutionMetadata.LabelsEntryR\x06labels\x12X\n\x0b\x61nnotations\x18\x04 \x03(\x0b\x32\x36.flyteidl.admin.TaskExecutionMetadata.AnnotationsEntryR\x0b\x61nnotations\x12.\n\x13k8s_service_account\x18\x05 \x01(\tR\x11k8sServiceAccount\x12t\n\x15\x65nvironment_variables\x18\x06 \x03(\x0b\x32?.flyteidl.admin.TaskExecutionMetadata.EnvironmentVariablesEntryR\x14\x65nvironmentVariables\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aG\n\x19\x45nvironmentVariablesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"\x83\x02\n\x11\x43reateTaskRequest\x12\x31\n\x06inputs\x18\x01 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x06inputs\x12\x37\n\x08template\x18\x02 \x01(\x0b\x32\x1b.flyteidl.core.TaskTemplateR\x08template\x12#\n\routput_prefix\x18\x03 \x01(\tR\x0coutputPrefix\x12]\n\x17task_execution_metadata\x18\x04 \x01(\x0b\x32%.flyteidl.admin.TaskExecutionMetadataR\x15taskExecutionMetadata\"z\n\x12\x43reateTaskResponse\x12%\n\rresource_meta\x18\x01 \x01(\x0cH\x00R\x0cresourceMeta\x12\x36\n\x08resource\x18\x02 \x01(\x0b\x32\x18.flyteidl.admin.ResourceH\x00R\x08resourceB\x05\n\x03res\"R\n\x0eGetTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"|\n\x0fGetTaskResponse\x12\x34\n\x08resource\x18\x01 \x01(\x0b\x32\x18.flyteidl.admin.ResourceR\x08resource\x12\x33\n\tlog_links\x18\x02 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\"\xf5\x01\n\x08Resource\x12+\n\x05state\x18\x01 \x01(\x0e\x32\x15.flyteidl.admin.StateR\x05state\x12\x33\n\x07outputs\x18\x02 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x07outputs\x12\x18\n\x07message\x18\x03 \x01(\tR\x07message\x12\x33\n\tlog_links\x18\x04 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\x12\x38\n\x05phase\x18\x05 \x01(\x0e\x32\".flyteidl.core.TaskExecution.PhaseR\x05phase\"U\n\x11\x44\x65leteTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"\x14\n\x12\x44\x65leteTaskResponse\"M\n\x05\x41gent\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x30\n\x14supported_task_types\x18\x02 \x03(\tR\x12supportedTaskTypes\"%\n\x0fGetAgentRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\"?\n\x10GetAgentResponse\x12+\n\x05\x61gent\x18\x01 \x01(\x0b\x32\x15.flyteidl.admin.AgentR\x05\x61gent\"\x13\n\x11ListAgentsRequest\"C\n\x12ListAgentsResponse\x12-\n\x06\x61gents\x18\x01 \x03(\x0b\x32\x15.flyteidl.admin.AgentR\x06\x61gents\"\x94\x02\n\x15GetTaskMetricsRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\x12\x18\n\x07queries\x18\x03 \x03(\tR\x07queries\x12\x39\n\nstart_time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.TimestampR\tstartTime\x12\x35\n\x08\x65nd_time\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.TimestampR\x07\x65ndTime\x12-\n\x04step\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationR\x04step\"X\n\x16GetTaskMetricsResponse\x12>\n\x07results\x18\x01 \x03(\x0b\x32$.flyteidl.core.ExecutionMetricResultR\x07results\"\x82\x01\n\x12GetTaskLogsRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\x12\x14\n\x05lines\x18\x03 \x01(\x04R\x05lines\x12\x14\n\x05token\x18\x04 \x01(\tR\x05token\"E\n\x13GetTaskLogsResponse\x12\x18\n\x07results\x18\x01 \x03(\tR\x07results\x12\x14\n\x05token\x18\x02 \x01(\tR\x05token*^\n\x05State\x12\x15\n\x11RETRYABLE_FAILURE\x10\x00\x12\x15\n\x11PERMANENT_FAILURE\x10\x01\x12\x0b\n\x07PENDING\x10\x02\x12\x0b\n\x07RUNNING\x10\x03\x12\r\n\tSUCCEEDED\x10\x04\x42\xb6\x01\n\x12\x63om.flyteidl.adminB\nAgentProtoP\x01Z;github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin\xa2\x02\x03\x46\x41X\xaa\x02\x0e\x46lyteidl.Admin\xca\x02\x0e\x46lyteidl\\Admin\xe2\x02\x1a\x46lyteidl\\Admin\\GPBMetadata\xea\x02\x0f\x46lyteidl::Adminb\x06proto3')
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1a\x66lyteidl/admin/agent.proto\x12\x0e\x66lyteidl.admin\x1a\x1c\x66lyteidl/core/literals.proto\x1a\x19\x66lyteidl/core/tasks.proto\x1a\x1e\x66lyteidl/core/identifier.proto\x1a\x1d\x66lyteidl/core/execution.proto\x1a\x1b\x66lyteidl/core/metrics.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\x98\x05\n\x15TaskExecutionMetadata\x12R\n\x11task_execution_id\x18\x01 \x01(\x0b\x32&.flyteidl.core.TaskExecutionIdentifierR\x0ftaskExecutionId\x12\x1c\n\tnamespace\x18\x02 \x01(\tR\tnamespace\x12I\n\x06labels\x18\x03 \x03(\x0b\x32\x31.flyteidl.admin.TaskExecutionMetadata.LabelsEntryR\x06labels\x12X\n\x0b\x61nnotations\x18\x04 \x03(\x0b\x32\x36.flyteidl.admin.TaskExecutionMetadata.AnnotationsEntryR\x0b\x61nnotations\x12.\n\x13k8s_service_account\x18\x05 \x01(\tR\x11k8sServiceAccount\x12t\n\x15\x65nvironment_variables\x18\x06 \x03(\x0b\x32?.flyteidl.admin.TaskExecutionMetadata.EnvironmentVariablesEntryR\x14\x65nvironmentVariables\x1a\x39\n\x0bLabelsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1a>\n\x10\x41nnotationsEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\x1aG\n\x19\x45nvironmentVariablesEntry\x12\x10\n\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n\x05value\x18\x02 \x01(\tR\x05value:\x02\x38\x01\"\x83\x02\n\x11\x43reateTaskRequest\x12\x31\n\x06inputs\x18\x01 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x06inputs\x12\x37\n\x08template\x18\x02 \x01(\x0b\x32\x1b.flyteidl.core.TaskTemplateR\x08template\x12#\n\routput_prefix\x18\x03 \x01(\tR\x0coutputPrefix\x12]\n\x17task_execution_metadata\x18\x04 \x01(\x0b\x32%.flyteidl.admin.TaskExecutionMetadataR\x15taskExecutionMetadata\"z\n\x12\x43reateTaskResponse\x12%\n\rresource_meta\x18\x01 \x01(\x0cH\x00R\x0cresourceMeta\x12\x36\n\x08resource\x18\x02 \x01(\x0b\x32\x18.flyteidl.admin.ResourceH\x00R\x08resourceB\x05\n\x03res\"R\n\x0eGetTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"|\n\x0fGetTaskResponse\x12\x34\n\x08resource\x18\x01 \x01(\x0b\x32\x18.flyteidl.admin.ResourceR\x08resource\x12\x33\n\tlog_links\x18\x02 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\"\xf9\x01\n\x08Resource\x12/\n\x05state\x18\x01 \x01(\x0e\x32\x15.flyteidl.admin.StateB\x02\x18\x01R\x05state\x12\x33\n\x07outputs\x18\x02 \x01(\x0b\x32\x19.flyteidl.core.LiteralMapR\x07outputs\x12\x18\n\x07message\x18\x03 \x01(\tR\x07message\x12\x33\n\tlog_links\x18\x04 \x03(\x0b\x32\x16.flyteidl.core.TaskLogR\x08logLinks\x12\x38\n\x05phase\x18\x05 \x01(\x0e\x32\".flyteidl.core.TaskExecution.PhaseR\x05phase\"U\n\x11\x44\x65leteTaskRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\"\x14\n\x12\x44\x65leteTaskResponse\"M\n\x05\x41gent\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\x12\x30\n\x14supported_task_types\x18\x02 \x03(\tR\x12supportedTaskTypes\"%\n\x0fGetAgentRequest\x12\x12\n\x04name\x18\x01 \x01(\tR\x04name\"?\n\x10GetAgentResponse\x12+\n\x05\x61gent\x18\x01 \x01(\x0b\x32\x15.flyteidl.admin.AgentR\x05\x61gent\"\x13\n\x11ListAgentsRequest\"C\n\x12ListAgentsResponse\x12-\n\x06\x61gents\x18\x01 \x03(\x0b\x32\x15.flyteidl.admin.AgentR\x06\x61gents\"\x94\x02\n\x15GetTaskMetricsRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\x12\x18\n\x07queries\x18\x03 \x03(\tR\x07queries\x12\x39\n\nstart_time\x18\x04 \x01(\x0b\x32\x1a.google.protobuf.TimestampR\tstartTime\x12\x35\n\x08\x65nd_time\x18\x05 \x01(\x0b\x32\x1a.google.protobuf.TimestampR\x07\x65ndTime\x12-\n\x04step\x18\x06 \x01(\x0b\x32\x19.google.protobuf.DurationR\x04step\"X\n\x16GetTaskMetricsResponse\x12>\n\x07results\x18\x01 \x03(\x0b\x32$.flyteidl.core.ExecutionMetricResultR\x07results\"\x82\x01\n\x12GetTaskLogsRequest\x12\x1b\n\ttask_type\x18\x01 \x01(\tR\x08taskType\x12#\n\rresource_meta\x18\x02 \x01(\x0cR\x0cresourceMeta\x12\x14\n\x05lines\x18\x03 \x01(\x04R\x05lines\x12\x14\n\x05token\x18\x04 \x01(\tR\x05token\"E\n\x13GetTaskLogsResponse\x12\x18\n\x07results\x18\x01 \x03(\tR\x07results\x12\x14\n\x05token\x18\x02 \x01(\tR\x05token*^\n\x05State\x12\x15\n\x11RETRYABLE_FAILURE\x10\x00\x12\x15\n\x11PERMANENT_FAILURE\x10\x01\x12\x0b\n\x07PENDING\x10\x02\x12\x0b\n\x07RUNNING\x10\x03\x12\r\n\tSUCCEEDED\x10\x04\x42\xb6\x01\n\x12\x63om.flyteidl.adminB\nAgentProtoP\x01Z;github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin\xa2\x02\x03\x46\x41X\xaa\x02\x0e\x46lyteidl.Admin\xca\x02\x0e\x46lyteidl\\Admin\xe2\x02\x1a\x46lyteidl\\Admin\\GPBMetadata\xea\x02\x0f\x46lyteidl::Adminb\x06proto3')
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
@@ -35,8 +35,10 @@
_TASKEXECUTIONMETADATA_ANNOTATIONSENTRY._serialized_options = b'8\001'
_TASKEXECUTIONMETADATA_ENVIRONMENTVARIABLESENTRY._options = None
_TASKEXECUTIONMETADATA_ENVIRONMENTVARIABLESENTRY._serialized_options = b'8\001'
- _globals['_STATE']._serialized_start=2726
- _globals['_STATE']._serialized_end=2820
+ _RESOURCE.fields_by_name['state']._options = None
+ _RESOURCE.fields_by_name['state']._serialized_options = b'\030\001'
+ _globals['_STATE']._serialized_start=2730
+ _globals['_STATE']._serialized_end=2824
_globals['_TASKEXECUTIONMETADATA']._serialized_start=261
_globals['_TASKEXECUTIONMETADATA']._serialized_end=925
_globals['_TASKEXECUTIONMETADATA_LABELSENTRY']._serialized_start=731
@@ -54,27 +56,27 @@
_globals['_GETTASKRESPONSE']._serialized_start=1397
_globals['_GETTASKRESPONSE']._serialized_end=1521
_globals['_RESOURCE']._serialized_start=1524
- _globals['_RESOURCE']._serialized_end=1769
- _globals['_DELETETASKREQUEST']._serialized_start=1771
- _globals['_DELETETASKREQUEST']._serialized_end=1856
- _globals['_DELETETASKRESPONSE']._serialized_start=1858
- _globals['_DELETETASKRESPONSE']._serialized_end=1878
- _globals['_AGENT']._serialized_start=1880
- _globals['_AGENT']._serialized_end=1957
- _globals['_GETAGENTREQUEST']._serialized_start=1959
- _globals['_GETAGENTREQUEST']._serialized_end=1996
- _globals['_GETAGENTRESPONSE']._serialized_start=1998
- _globals['_GETAGENTRESPONSE']._serialized_end=2061
- _globals['_LISTAGENTSREQUEST']._serialized_start=2063
- _globals['_LISTAGENTSREQUEST']._serialized_end=2082
- _globals['_LISTAGENTSRESPONSE']._serialized_start=2084
- _globals['_LISTAGENTSRESPONSE']._serialized_end=2151
- _globals['_GETTASKMETRICSREQUEST']._serialized_start=2154
- _globals['_GETTASKMETRICSREQUEST']._serialized_end=2430
- _globals['_GETTASKMETRICSRESPONSE']._serialized_start=2432
- _globals['_GETTASKMETRICSRESPONSE']._serialized_end=2520
- _globals['_GETTASKLOGSREQUEST']._serialized_start=2523
- _globals['_GETTASKLOGSREQUEST']._serialized_end=2653
- _globals['_GETTASKLOGSRESPONSE']._serialized_start=2655
- _globals['_GETTASKLOGSRESPONSE']._serialized_end=2724
+ _globals['_RESOURCE']._serialized_end=1773
+ _globals['_DELETETASKREQUEST']._serialized_start=1775
+ _globals['_DELETETASKREQUEST']._serialized_end=1860
+ _globals['_DELETETASKRESPONSE']._serialized_start=1862
+ _globals['_DELETETASKRESPONSE']._serialized_end=1882
+ _globals['_AGENT']._serialized_start=1884
+ _globals['_AGENT']._serialized_end=1961
+ _globals['_GETAGENTREQUEST']._serialized_start=1963
+ _globals['_GETAGENTREQUEST']._serialized_end=2000
+ _globals['_GETAGENTRESPONSE']._serialized_start=2002
+ _globals['_GETAGENTRESPONSE']._serialized_end=2065
+ _globals['_LISTAGENTSREQUEST']._serialized_start=2067
+ _globals['_LISTAGENTSREQUEST']._serialized_end=2086
+ _globals['_LISTAGENTSRESPONSE']._serialized_start=2088
+ _globals['_LISTAGENTSRESPONSE']._serialized_end=2155
+ _globals['_GETTASKMETRICSREQUEST']._serialized_start=2158
+ _globals['_GETTASKMETRICSREQUEST']._serialized_end=2434
+ _globals['_GETTASKMETRICSRESPONSE']._serialized_start=2436
+ _globals['_GETTASKMETRICSRESPONSE']._serialized_end=2524
+ _globals['_GETTASKLOGSREQUEST']._serialized_start=2527
+ _globals['_GETTASKLOGSREQUEST']._serialized_end=2657
+ _globals['_GETTASKLOGSRESPONSE']._serialized_start=2659
+ _globals['_GETTASKLOGSRESPONSE']._serialized_end=2728
# @@protoc_insertion_point(module_scope)
diff --git a/flyteidl/gen/pb_rust/flyteidl.admin.rs b/flyteidl/gen/pb_rust/flyteidl.admin.rs
index f52aed14a4..56d2426597 100644
--- a/flyteidl/gen/pb_rust/flyteidl.admin.rs
+++ b/flyteidl/gen/pb_rust/flyteidl.admin.rs
@@ -88,6 +88,7 @@ pub struct GetTaskResponse {
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Resource {
/// DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
+ #[deprecated]
#[prost(enumeration="State", tag="1")]
pub state: i32,
/// The outputs of the execution. It's typically used by sql task. Agent service will create a
diff --git a/flyteidl/protos/flyteidl/admin/agent.proto b/flyteidl/protos/flyteidl/admin/agent.proto
index 3aa3abe829..5b7043e86f 100644
--- a/flyteidl/protos/flyteidl/admin/agent.proto
+++ b/flyteidl/protos/flyteidl/admin/agent.proto
@@ -79,7 +79,7 @@ message GetTaskResponse {
message Resource {
// DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
- State state = 1;
+ State state = 1 [deprecated = true];
// The outputs of the execution. It's typically used by sql task. Agent service will create a
// Structured dataset pointing to the query result table.
// +optional
diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
index 93da6aa3ee..7a9f92caaa 100644
--- a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
+++ b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
@@ -193,7 +193,6 @@ func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase
resource := taskCtx.Resource().(ResourceWrapper)
taskInfo := &core.TaskInfo{Logs: resource.LogLinks}
- // If the phase is undefined, we will use state to determine the phase.
switch resource.Phase {
case flyteIdl.TaskExecution_QUEUED:
return core.PhaseInfoQueuedWithTaskInfo(core.DefaultPhaseVersion, resource.Message, taskInfo), nil
@@ -216,8 +215,12 @@ func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase
return core.PhaseInfoFailure(pluginErrors.TaskFailedWithError, "failed to run the job", taskInfo), nil
}
- logger.Infof(ctx, "Agent returned an undefined phase [%v]. Checking state.", resource.Phase)
+ // The default phase is undefined.
+ if resource.Phase != flyteIdl.TaskExecution_UNDEFINED {
+ return core.PhaseInfoUndefined, pluginErrors.Errorf(core.SystemErrorCode, "unknown execution phase [%v].", resource.Phase)
+ }
+ // If the phase is undefined, we will use state to determine the phase.
switch resource.State {
case admin.State_PENDING:
return core.PhaseInfoInitializing(time.Now(), core.DefaultPhaseVersion, resource.Message, taskInfo), nil
@@ -235,7 +238,7 @@ func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase
}
return core.PhaseInfoSuccess(taskInfo), nil
}
- return core.PhaseInfoUndefined, pluginErrors.Errorf(core.SystemErrorCode, "unknown execution phase [%v].", resource.State)
+ return core.PhaseInfoUndefined, pluginErrors.Errorf(core.SystemErrorCode, "unknown execution state [%v].", resource.State)
}
func writeOutput(ctx context.Context, taskCtx webapi.StatusContext, resource ResourceWrapper) error {
diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin_test.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin_test.go
index 7d9e03e778..d5b5fae5fe 100644
--- a/flyteplugins/go/tasks/plugins/webapi/agent/plugin_test.go
+++ b/flyteplugins/go/tasks/plugins/webapi/agent/plugin_test.go
@@ -318,6 +318,20 @@ func TestPlugin(t *testing.T) {
assert.NoError(t, err)
assert.Equal(t, pluginsCore.PhasePermanentFailure, phase.Phase())
})
+
+ t.Run("test UNDEFINED Phase", func(t *testing.T) {
+ taskContext := new(webapiPlugin.StatusContext)
+ taskContext.On("Resource").Return(ResourceWrapper{
+ State: 8,
+ Outputs: nil,
+ Message: "",
+ LogLinks: []*flyteIdlCore.TaskLog{{Uri: "http://localhost:3000/log", Name: "Log Link"}},
+ })
+
+ phase, err := plugin.Status(context.Background(), taskContext)
+ assert.Error(t, err)
+ assert.Equal(t, pluginsCore.PhaseUndefined, phase.Phase())
+ })
}
func TestInitializeAgentRegistry(t *testing.T) {