diff --git a/workflows/chip-cre.json b/workflows/chip-cre.json index d009bc33..08860f57 100644 --- a/workflows/chip-cre.json +++ b/workflows/chip-cre.json @@ -247,6 +247,22 @@ } ] }, + { + "entity": "workflows.v2.WorkflowActivationAbandoned", + "path": "workflows/v2/workflow_activation_abandoned.proto", + "references": [ + { + "name": "workflows/v2/cre_info.proto", + "entity": "workflows.v2.CreInfo", + "path": "workflows/v2/cre_info.proto" + }, + { + "name": "workflows/v2/workflow.proto", + "entity": "workflows.v2.Workflow", + "path": "workflows/v2/workflow.proto" + } + ] + }, { "entity": "workflows.v2.WorkflowDeleted", "path": "workflows/v2/workflow_deleted.proto", diff --git a/workflows/chip-platform.json b/workflows/chip-platform.json index 7dbd8f16..3e1bb2b0 100644 --- a/workflows/chip-platform.json +++ b/workflows/chip-platform.json @@ -247,6 +247,22 @@ } ] }, + { + "entity": "workflows.v2.WorkflowActivationAbandoned", + "path": "workflows/v2/workflow_activation_abandoned.proto", + "references": [ + { + "name": "workflows/v2/cre_info.proto", + "entity": "workflows.v2.CreInfo", + "path": "workflows/v2/cre_info.proto" + }, + { + "name": "workflows/v2/workflow.proto", + "entity": "workflows.v2.Workflow", + "path": "workflows/v2/workflow.proto" + } + ] + }, { "entity": "workflows.v2.WorkflowDeleted", "path": "workflows/v2/workflow_deleted.proto", diff --git a/workflows/go/generate.go b/workflows/go/generate.go index 73a2d2e0..30745ffe 100644 --- a/workflows/go/generate.go +++ b/workflows/go/generate.go @@ -23,6 +23,7 @@ package workflows //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_deleted.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_paused.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_activated.proto +//go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_activation_abandoned.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/trigger_execution_started.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_execution_started.proto //go:generate protoc --proto_path=../ --go_out=./ --go_opt=module=github.com/smartcontractkit/chainlink-protos/workflows/go ../workflows/v2/workflow_execution_finished.proto diff --git a/workflows/go/v2/workflow_activation_abandoned.pb.go b/workflows/go/v2/workflow_activation_abandoned.pb.go new file mode 100644 index 00000000..8022e143 --- /dev/null +++ b/workflows/go/v2/workflow_activation_abandoned.pb.go @@ -0,0 +1,232 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.36.6 +// protoc v5.29.3 +// source: workflows/v2/workflow_activation_abandoned.proto + +package v2 + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" + unsafe "unsafe" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type ActivationAbandonReason int32 + +const ( + ActivationAbandonReason_ACTIVATION_ABANDON_REASON_UNSPECIFIED ActivationAbandonReason = 0 + ActivationAbandonReason_ACTIVATION_ABANDON_REASON_NON_RETRYABLE ActivationAbandonReason = 1 + ActivationAbandonReason_ACTIVATION_ABANDON_REASON_RETRY_LIMIT_EXCEEDED ActivationAbandonReason = 2 +) + +// Enum value maps for ActivationAbandonReason. +var ( + ActivationAbandonReason_name = map[int32]string{ + 0: "ACTIVATION_ABANDON_REASON_UNSPECIFIED", + 1: "ACTIVATION_ABANDON_REASON_NON_RETRYABLE", + 2: "ACTIVATION_ABANDON_REASON_RETRY_LIMIT_EXCEEDED", + } + ActivationAbandonReason_value = map[string]int32{ + "ACTIVATION_ABANDON_REASON_UNSPECIFIED": 0, + "ACTIVATION_ABANDON_REASON_NON_RETRYABLE": 1, + "ACTIVATION_ABANDON_REASON_RETRY_LIMIT_EXCEEDED": 2, + } +) + +func (x ActivationAbandonReason) Enum() *ActivationAbandonReason { + p := new(ActivationAbandonReason) + *p = x + return p +} + +func (x ActivationAbandonReason) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (ActivationAbandonReason) Descriptor() protoreflect.EnumDescriptor { + return file_workflows_v2_workflow_activation_abandoned_proto_enumTypes[0].Descriptor() +} + +func (ActivationAbandonReason) Type() protoreflect.EnumType { + return &file_workflows_v2_workflow_activation_abandoned_proto_enumTypes[0] +} + +func (x ActivationAbandonReason) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Use ActivationAbandonReason.Descriptor instead. +func (ActivationAbandonReason) EnumDescriptor() ([]byte, []int) { + return file_workflows_v2_workflow_activation_abandoned_proto_rawDescGZIP(), []int{0} +} + +type WorkflowActivationAbandoned struct { + state protoimpl.MessageState `protogen:"open.v1"` + CreInfo *CreInfo `protobuf:"bytes,1,opt,name=creInfo,proto3" json:"creInfo,omitempty"` + Workflow *Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"` + Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix timestamp + ErrorMessage string `protobuf:"bytes,4,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"` + Reason ActivationAbandonReason `protobuf:"varint,5,opt,name=reason,proto3,enum=workflows.v2.ActivationAbandonReason" json:"reason,omitempty"` + RetryCount int32 `protobuf:"varint,6,opt,name=retryCount,proto3" json:"retryCount,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *WorkflowActivationAbandoned) Reset() { + *x = WorkflowActivationAbandoned{} + mi := &file_workflows_v2_workflow_activation_abandoned_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *WorkflowActivationAbandoned) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*WorkflowActivationAbandoned) ProtoMessage() {} + +func (x *WorkflowActivationAbandoned) ProtoReflect() protoreflect.Message { + mi := &file_workflows_v2_workflow_activation_abandoned_proto_msgTypes[0] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use WorkflowActivationAbandoned.ProtoReflect.Descriptor instead. +func (*WorkflowActivationAbandoned) Descriptor() ([]byte, []int) { + return file_workflows_v2_workflow_activation_abandoned_proto_rawDescGZIP(), []int{0} +} + +func (x *WorkflowActivationAbandoned) GetCreInfo() *CreInfo { + if x != nil { + return x.CreInfo + } + return nil +} + +func (x *WorkflowActivationAbandoned) GetWorkflow() *Workflow { + if x != nil { + return x.Workflow + } + return nil +} + +func (x *WorkflowActivationAbandoned) GetTimestamp() uint64 { + if x != nil { + return x.Timestamp + } + return 0 +} + +func (x *WorkflowActivationAbandoned) GetErrorMessage() string { + if x != nil { + return x.ErrorMessage + } + return "" +} + +func (x *WorkflowActivationAbandoned) GetReason() ActivationAbandonReason { + if x != nil { + return x.Reason + } + return ActivationAbandonReason_ACTIVATION_ABANDON_REASON_UNSPECIFIED +} + +func (x *WorkflowActivationAbandoned) GetRetryCount() int32 { + if x != nil { + return x.RetryCount + } + return 0 +} + +var File_workflows_v2_workflow_activation_abandoned_proto protoreflect.FileDescriptor + +const file_workflows_v2_workflow_activation_abandoned_proto_rawDesc = "" + + "\n" + + "0workflows/v2/workflow_activation_abandoned.proto\x12\fworkflows.v2\x1a\x1bworkflows/v2/cre_info.proto\x1a\x1bworkflows/v2/workflow.proto\"\xa3\x02\n" + + "\x1bWorkflowActivationAbandoned\x12/\n" + + "\acreInfo\x18\x01 \x01(\v2\x15.workflows.v2.CreInfoR\acreInfo\x122\n" + + "\bworkflow\x18\x02 \x01(\v2\x16.workflows.v2.WorkflowR\bworkflow\x12\x1c\n" + + "\ttimestamp\x18\x03 \x01(\x04R\ttimestamp\x12\"\n" + + "\ferrorMessage\x18\x04 \x01(\tR\ferrorMessage\x12=\n" + + "\x06reason\x18\x05 \x01(\x0e2%.workflows.v2.ActivationAbandonReasonR\x06reason\x12\x1e\n" + + "\n" + + "retryCount\x18\x06 \x01(\x05R\n" + + "retryCount*\xa5\x01\n" + + "\x17ActivationAbandonReason\x12)\n" + + "%ACTIVATION_ABANDON_REASON_UNSPECIFIED\x10\x00\x12+\n" + + "'ACTIVATION_ABANDON_REASON_NON_RETRYABLE\x10\x01\x122\n" + + ".ACTIVATION_ABANDON_REASON_RETRY_LIMIT_EXCEEDED\x10\x02B>Z workflows.v2.CreInfo + 3, // 1: workflows.v2.WorkflowActivationAbandoned.workflow:type_name -> workflows.v2.Workflow + 0, // 2: workflows.v2.WorkflowActivationAbandoned.reason:type_name -> workflows.v2.ActivationAbandonReason + 3, // [3:3] is the sub-list for method output_type + 3, // [3:3] is the sub-list for method input_type + 3, // [3:3] is the sub-list for extension type_name + 3, // [3:3] is the sub-list for extension extendee + 0, // [0:3] is the sub-list for field type_name +} + +func init() { file_workflows_v2_workflow_activation_abandoned_proto_init() } +func file_workflows_v2_workflow_activation_abandoned_proto_init() { + if File_workflows_v2_workflow_activation_abandoned_proto != nil { + return + } + file_workflows_v2_cre_info_proto_init() + file_workflows_v2_workflow_proto_init() + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: unsafe.Slice(unsafe.StringData(file_workflows_v2_workflow_activation_abandoned_proto_rawDesc), len(file_workflows_v2_workflow_activation_abandoned_proto_rawDesc)), + NumEnums: 1, + NumMessages: 1, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_workflows_v2_workflow_activation_abandoned_proto_goTypes, + DependencyIndexes: file_workflows_v2_workflow_activation_abandoned_proto_depIdxs, + EnumInfos: file_workflows_v2_workflow_activation_abandoned_proto_enumTypes, + MessageInfos: file_workflows_v2_workflow_activation_abandoned_proto_msgTypes, + }.Build() + File_workflows_v2_workflow_activation_abandoned_proto = out.File + file_workflows_v2_workflow_activation_abandoned_proto_goTypes = nil + file_workflows_v2_workflow_activation_abandoned_proto_depIdxs = nil +} diff --git a/workflows/iron-flask-cre.yaml b/workflows/iron-flask-cre.yaml index 21994962..abfca1e3 100644 --- a/workflows/iron-flask-cre.yaml +++ b/workflows/iron-flask-cre.yaml @@ -165,6 +165,16 @@ beholder: subject: "beholder__cre__messages-workflows.v2.Workflow" version: 1 + - entity: WorkflowActivationAbandoned + schema: "workflows/v2/workflow_activation_abandoned.proto" + references: + - name: "workflows/v2/cre_info.proto" + subject: "beholder__cre__messages-workflows.v2.CreInfo" + version: 1 + - name: "workflows/v2/workflow.proto" + subject: "beholder__cre__messages-workflows.v2.Workflow" + version: 1 + - entity: WorkflowDeleted schema: "workflows/v2/workflow_deleted.proto" references: diff --git a/workflows/iron-flask-platform.yaml b/workflows/iron-flask-platform.yaml index e22ae856..25419028 100644 --- a/workflows/iron-flask-platform.yaml +++ b/workflows/iron-flask-platform.yaml @@ -165,6 +165,16 @@ beholder: subject: "beholder__platform__messages-workflows.v2.Workflow" version: 1 + - entity: WorkflowActivationAbandoned + schema: "workflows/v2/workflow_activation_abandoned.proto" + references: + - name: "workflows/v2/cre_info.proto" + subject: "beholder__platform__messages-workflows.v2.CreInfo" + version: 1 + - name: "workflows/v2/workflow.proto" + subject: "beholder__platform__messages-workflows.v2.Workflow" + version: 1 + - entity: WorkflowDeleted schema: "workflows/v2/workflow_deleted.proto" references: diff --git a/workflows/workflows/v2/workflow_activation_abandoned.proto b/workflows/workflows/v2/workflow_activation_abandoned.proto new file mode 100644 index 00000000..e9941ea7 --- /dev/null +++ b/workflows/workflows/v2/workflow_activation_abandoned.proto @@ -0,0 +1,23 @@ +syntax = "proto3"; + +package workflows.v2; + +import "workflows/v2/cre_info.proto"; +import "workflows/v2/workflow.proto"; + +option go_package = "github.com/smartcontractkit/chainlink-protos/workflows/go/v2"; + +enum ActivationAbandonReason { + ACTIVATION_ABANDON_REASON_UNSPECIFIED = 0; + ACTIVATION_ABANDON_REASON_NON_RETRYABLE = 1; + ACTIVATION_ABANDON_REASON_RETRY_LIMIT_EXCEEDED = 2; +} + +message WorkflowActivationAbandoned { + CreInfo creInfo = 1; + Workflow workflow = 2; + uint64 timestamp = 3; // unix timestamp + string errorMessage = 4; + ActivationAbandonReason reason = 5; + int32 retryCount = 6; +}