diff --git a/api/historyservice/v1/request_response.pb.go b/api/historyservice/v1/request_response.pb.go index 3d382e4520a..0dbd00704f2 100644 --- a/api/historyservice/v1/request_response.pb.go +++ b/api/historyservice/v1/request_response.pb.go @@ -80,9 +80,11 @@ type StartWorkflowExecutionRequest struct { Attempt int32 `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"` WorkflowExecutionExpirationTime *time.Time `protobuf:"bytes,5,opt,name=workflow_execution_expiration_time,json=workflowExecutionExpirationTime,proto3,stdtime" json:"workflow_execution_expiration_time,omitempty"` ContinueAsNewInitiator v12.ContinueAsNewInitiator `protobuf:"varint,6,opt,name=continue_as_new_initiator,json=continueAsNewInitiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"continue_as_new_initiator,omitempty"` - ContinuedFailure *v13.Failure `protobuf:"bytes,7,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"` - LastCompletionResult *v14.Payloads `protobuf:"bytes,8,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` - FirstWorkflowTaskBackoff *time.Duration `protobuf:"bytes,9,opt,name=first_workflow_task_backoff,json=firstWorkflowTaskBackoff,proto3,stdduration" json:"first_workflow_task_backoff,omitempty"` + // History service should use the values of continued_failure and last_completion_result + // here, not the ones in start_request (those are moved into here in the frontend). + ContinuedFailure *v13.Failure `protobuf:"bytes,7,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"` + LastCompletionResult *v14.Payloads `protobuf:"bytes,8,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` + FirstWorkflowTaskBackoff *time.Duration `protobuf:"bytes,9,opt,name=first_workflow_task_backoff,json=firstWorkflowTaskBackoff,proto3,stdduration" json:"first_workflow_task_backoff,omitempty"` } func (m *StartWorkflowExecutionRequest) Reset() { *m = StartWorkflowExecutionRequest{} } diff --git a/api/schedule/v1/message.pb.go b/api/schedule/v1/message.pb.go index c823ac27f11..4e6f6d7d89b 100644 --- a/api/schedule/v1/message.pb.go +++ b/api/schedule/v1/message.pb.go @@ -573,8 +573,6 @@ func (*WatchWorkflowResponse) XXX_OneofWrappers() []interface{} { type StartWorkflowRequest struct { Request *v14.StartWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` - LastCompletionResult *v11.Payloads `protobuf:"bytes,4,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` - ContinuedFailure *v12.Failure `protobuf:"bytes,5,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"` CompletedRateLimitSleep bool `protobuf:"varint,6,opt,name=completed_rate_limit_sleep,json=completedRateLimitSleep,proto3" json:"completed_rate_limit_sleep,omitempty"` } @@ -617,20 +615,6 @@ func (m *StartWorkflowRequest) GetRequest() *v14.StartWorkflowExecutionRequest { return nil } -func (m *StartWorkflowRequest) GetLastCompletionResult() *v11.Payloads { - if m != nil { - return m.LastCompletionResult - } - return nil -} - -func (m *StartWorkflowRequest) GetContinuedFailure() *v12.Failure { - if m != nil { - return m.ContinuedFailure - } - return nil -} - func (m *StartWorkflowRequest) GetCompletedRateLimitSleep() bool { if m != nil { return m.CompletedRateLimitSleep @@ -844,79 +828,79 @@ func init() { } var fileDescriptor_6461b6986ba20ee7 = []byte{ - // 1150 bytes of a gzipped FileDescriptorProto - 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x57, 0x4f, 0x6f, 0x1b, 0xc5, - 0x1b, 0xf6, 0xda, 0x8e, 0x6b, 0x8f, 0x63, 0x37, 0xd9, 0x26, 0xf9, 0x59, 0xfe, 0xc1, 0xc6, 0xb5, - 0x68, 0x09, 0x12, 0xac, 0x95, 0x54, 0xe2, 0xd0, 0xa2, 0x4a, 0x4d, 0x4a, 0x88, 0x51, 0x11, 0xd6, - 0x38, 0x10, 0xc4, 0x65, 0x35, 0xd9, 0x1d, 0x3b, 0xa3, 0xce, 0xce, 0x2c, 0x3b, 0xb3, 0x69, 0xc3, - 0x89, 0x03, 0x57, 0xa4, 0x7e, 0x07, 0x2e, 0x5c, 0x11, 0x82, 0xcf, 0xc0, 0x31, 0xc7, 0x8a, 0x0b, - 0xc4, 0xb9, 0x20, 0x71, 0xe9, 0x47, 0x40, 0x33, 0x3b, 0xeb, 0xc4, 0x4e, 0xd2, 0x04, 0x8a, 0x84, - 0xb8, 0xf9, 0x7d, 0xe7, 0x7d, 0x9e, 0x79, 0xf7, 0xfd, 0xf3, 0xec, 0x1a, 0xbc, 0x23, 0x71, 0x18, - 0xf1, 0x18, 0xd1, 0x8e, 0xc0, 0xf1, 0x3e, 0x8e, 0x3b, 0x28, 0x22, 0x1d, 0xe1, 0xef, 0xe1, 0x20, - 0xa1, 0xb8, 0xb3, 0xbf, 0xda, 0x09, 0xb1, 0x10, 0x68, 0x88, 0xdd, 0x28, 0xe6, 0x92, 0xdb, 0xcb, - 0x59, 0xb8, 0x9b, 0x86, 0xbb, 0x28, 0x22, 0x6e, 0x16, 0xee, 0xee, 0xaf, 0x36, 0xdf, 0x18, 0xf3, - 0x29, 0x22, 0x9f, 0x87, 0x21, 0x67, 0x67, 0x68, 0x9a, 0xb7, 0x26, 0xa2, 0x06, 0x88, 0xd0, 0x24, - 0x3e, 0x7b, 0xdb, 0x14, 0x19, 0x66, 0x49, 0x28, 0x54, 0xd0, 0xf8, 0xbe, 0x97, 0x46, 0x3d, 0xe1, - 0xf1, 0xe3, 0x01, 0xe5, 0x4f, 0x4c, 0xd4, 0xed, 0x89, 0xa8, 0x0b, 0x9f, 0xb0, 0xf9, 0xee, 0x44, - 0x5c, 0x46, 0xa2, 0x9e, 0x96, 0xf8, 0x3a, 0x3c, 0xc6, 0x5f, 0x24, 0x58, 0x48, 0x2f, 0xc6, 0x22, - 0xe2, 0x4c, 0x64, 0xb8, 0xe5, 0x21, 0xe7, 0x43, 0x8a, 0x3b, 0xda, 0xda, 0x4d, 0x06, 0x1d, 0x49, - 0x42, 0x2c, 0x24, 0x0a, 0x23, 0x13, 0x70, 0x33, 0xc0, 0x11, 0x66, 0x01, 0x66, 0x3e, 0xc1, 0xa2, - 0x33, 0xe4, 0x43, 0xae, 0xfd, 0xfa, 0x57, 0x1a, 0xd2, 0xfe, 0x3a, 0x0f, 0x6a, 0xeb, 0xc9, 0x60, - 0x80, 0x63, 0x1c, 0xf4, 0x25, 0x8a, 0xa5, 0xbd, 0x01, 0x66, 0x19, 0x0f, 0x09, 0x43, 0xd4, 0x53, - 0x7c, 0x0d, 0xab, 0x65, 0xad, 0x54, 0xd7, 0x9a, 0x6e, 0x7a, 0x99, 0x9b, 0x5d, 0xe6, 0x6e, 0x67, - 0x97, 0xad, 0x17, 0x9f, 0xfd, 0xba, 0x6c, 0xc1, 0xaa, 0x41, 0x29, 0xbf, 0xfd, 0x00, 0x54, 0x91, - 0x2f, 0x93, 0x8c, 0x23, 0x7f, 0x45, 0x0e, 0x90, 0x82, 0x34, 0x45, 0x1f, 0xd4, 0xf9, 0x3e, 0x8e, - 0x29, 0x8a, 0xbc, 0x88, 0x53, 0xe2, 0x1f, 0x34, 0x0a, 0x2d, 0x6b, 0xa5, 0xbe, 0xf6, 0xb6, 0x3b, - 0x1e, 0x08, 0x35, 0x09, 0xba, 0xf8, 0xee, 0xfe, 0xaa, 0xdb, 0x37, 0xf5, 0xfd, 0x38, 0x05, 0xf5, - 0x34, 0x06, 0xd6, 0xf8, 0x69, 0xd3, 0x5e, 0x02, 0xa5, 0x10, 0xb1, 0x04, 0xd1, 0x46, 0xb1, 0x65, - 0xad, 0x94, 0xa1, 0xb1, 0xda, 0xdf, 0x14, 0x41, 0xad, 0xcb, 0x24, 0x8e, 0x19, 0xa2, 0x7d, 0x89, - 0x24, 0xb6, 0x5f, 0x03, 0x15, 0x86, 0x42, 0x2c, 0x22, 0xe4, 0xa7, 0x35, 0xa8, 0xc0, 0x13, 0x87, - 0x7d, 0x13, 0xcc, 0x8e, 0x0d, 0x8f, 0x04, 0xfa, 0x01, 0x2b, 0xb0, 0x3a, 0xf6, 0x75, 0x03, 0x7b, - 0x19, 0x54, 0xb3, 0x96, 0xab, 0x88, 0xb2, 0x8e, 0x00, 0x99, 0xab, 0x1b, 0xd8, 0x3d, 0x70, 0x83, - 0x22, 0x21, 0xbd, 0x28, 0xe6, 0x3e, 0x16, 0x02, 0x07, 0x69, 0xad, 0x0a, 0x57, 0xac, 0xd5, 0xbc, - 0x02, 0xf7, 0x32, 0xac, 0x2e, 0xd9, 0x0e, 0xb8, 0xbe, 0x6b, 0x7a, 0xe9, 0x09, 0xd5, 0x4c, 0xd1, - 0x28, 0xb6, 0x0a, 0x2b, 0xd5, 0x35, 0xd7, 0xbd, 0x64, 0x89, 0xdc, 0x89, 0x19, 0x80, 0xf5, 0xdd, - 0xd3, 0xa6, 0xb0, 0x3f, 0x05, 0x4b, 0x3a, 0x55, 0x9f, 0x87, 0x11, 0xc5, 0x92, 0x70, 0xa6, 0x66, - 0x31, 0xa1, 0xb2, 0x31, 0xa3, 0xb3, 0x6d, 0x4d, 0xf6, 0x24, 0xdd, 0x41, 0x45, 0xdb, 0x43, 0x07, - 0x94, 0xa3, 0x40, 0xc0, 0x05, 0x85, 0xdf, 0x18, 0xc3, 0xa1, 0x46, 0xdb, 0x1f, 0x81, 0x79, 0x9f, - 0x33, 0x49, 0x58, 0x82, 0x03, 0xcf, 0xec, 0x64, 0xa3, 0x74, 0x1e, 0xa5, 0x39, 0x54, 0x9c, 0x9b, - 0xe9, 0x4f, 0x38, 0x37, 0x86, 0x1a, 0x8f, 0x7d, 0x0b, 0xd4, 0x7d, 0xce, 0x06, 0x94, 0xf8, 0xd2, - 0x93, 0xfc, 0x31, 0x66, 0x8d, 0x6b, 0x2d, 0x6b, 0xa5, 0x00, 0x6b, 0x99, 0x77, 0x5b, 0x39, 0x75, - 0xf3, 0x30, 0x0e, 0xbc, 0x18, 0x0f, 0x62, 0x2c, 0xf6, 0x1a, 0x15, 0x3d, 0x0a, 0x55, 0xe5, 0x83, - 0xa9, 0xab, 0xfd, 0x6d, 0x1e, 0xcc, 0xeb, 0x67, 0xcf, 0xa6, 0xea, 0x41, 0x3c, 0x14, 0xf6, 0x7d, - 0x50, 0xce, 0x6a, 0x66, 0xd6, 0xa2, 0x3d, 0x99, 0xe5, 0xe9, 0x8a, 0x66, 0x48, 0x38, 0xc6, 0xd8, - 0x77, 0x41, 0x91, 0xb0, 0x01, 0x37, 0xeb, 0x70, 0xfb, 0x72, 0x6c, 0x97, 0x0d, 0x38, 0xd4, 0x18, - 0xfb, 0x11, 0xa8, 0x11, 0x46, 0x24, 0x41, 0xd4, 0x8b, 0x90, 0xf4, 0xf7, 0xcc, 0x9c, 0xbc, 0x79, - 0x39, 0x49, 0x4f, 0x85, 0xc3, 0x59, 0x83, 0xd6, 0x96, 0xfd, 0x10, 0xcc, 0x08, 0x35, 0xe6, 0x7a, - 0x0d, 0xae, 0x32, 0x1f, 0x13, 0xcb, 0x01, 0x53, 0x70, 0xfb, 0x4b, 0x30, 0xbf, 0x99, 0x50, 0xfa, - 0x49, 0x14, 0x28, 0x67, 0x2a, 0x52, 0xaf, 0x5c, 0xa4, 0xb3, 0x4d, 0xcc, 0x9f, 0xd3, 0xc4, 0xf6, - 0x8f, 0x16, 0x98, 0x7b, 0x88, 0x85, 0x1f, 0x93, 0x5d, 0x0c, 0x8d, 0x2e, 0xfe, 0xab, 0x0d, 0x3a, - 0x9b, 0x77, 0xe1, 0xbc, 0xbc, 0xbf, 0xb7, 0xc0, 0xc2, 0x8e, 0xea, 0xc1, 0x8e, 0xd1, 0xf9, 0xac, - 0x6e, 0x1f, 0x80, 0x0a, 0x7e, 0x8a, 0xfd, 0x44, 0xad, 0x87, 0x69, 0xee, 0x5b, 0x17, 0xad, 0x55, - 0x86, 0x7d, 0x3f, 0x03, 0xc0, 0x13, 0xac, 0x7d, 0x07, 0x2c, 0x0d, 0x48, 0x2c, 0xa4, 0x37, 0x76, - 0x79, 0x71, 0xc2, 0x94, 0x06, 0x15, 0xb5, 0x06, 0xdd, 0xd0, 0xa7, 0x27, 0xd0, 0x84, 0x75, 0x03, - 0xfb, 0xff, 0xa0, 0x42, 0x39, 0x1b, 0x2a, 0xa9, 0xa5, 0x7a, 0xa9, 0xcb, 0xb0, 0xac, 0x1c, 0x3d, - 0x4e, 0x69, 0xfb, 0x0f, 0x0b, 0x2c, 0x4e, 0xe5, 0x6c, 0x0a, 0xbe, 0x09, 0x4a, 0x6a, 0x14, 0x12, - 0xa1, 0xcb, 0x5d, 0x3f, 0x3d, 0x48, 0x13, 0xe2, 0x7c, 0x26, 0xe1, 0xbe, 0x46, 0x41, 0x83, 0xb6, - 0xef, 0x82, 0x92, 0x11, 0x94, 0xfc, 0xd5, 0x04, 0x65, 0x2b, 0x07, 0x0d, 0xc2, 0x7e, 0x0f, 0x5c, - 0xcb, 0xa4, 0xa3, 0x70, 0x35, 0xe9, 0xd8, 0xca, 0xc1, 0x0c, 0xb2, 0x3e, 0x07, 0xea, 0x29, 0x4f, - 0xa6, 0x3f, 0xed, 0x5f, 0xf2, 0x60, 0x41, 0xef, 0xfe, 0x74, 0x87, 0x3e, 0x03, 0xd7, 0xcc, 0x9b, - 0xd8, 0x64, 0x79, 0x7f, 0xf2, 0xa2, 0xa9, 0x37, 0xb7, 0x9e, 0x93, 0xd3, 0x3c, 0x27, 0x25, 0x4f, - 0x59, 0x60, 0x46, 0xf7, 0x12, 0x7d, 0x2d, 0xfe, 0xf3, 0xfa, 0x3a, 0xf3, 0xb7, 0xf5, 0xf5, 0x1e, - 0x68, 0x9a, 0x0c, 0x95, 0x7a, 0x22, 0x89, 0x3d, 0x4a, 0x42, 0x22, 0x3d, 0x41, 0x31, 0x8e, 0xb4, - 0x6e, 0x97, 0xe1, 0xff, 0xc6, 0x11, 0x10, 0x49, 0xfc, 0x48, 0x9d, 0xf7, 0xd5, 0xf1, 0x87, 0xc5, - 0x72, 0x61, 0xae, 0xd8, 0x7e, 0x0a, 0x16, 0xa7, 0x6a, 0x6b, 0x26, 0x69, 0x11, 0x94, 0xcc, 0x94, - 0xa6, 0x2f, 0xdb, 0x99, 0x58, 0xcf, 0xe5, 0x16, 0xb8, 0x1e, 0x63, 0x44, 0xd3, 0xd7, 0xd9, 0x5f, - 0xfb, 0x98, 0xa8, 0x29, 0xa0, 0xbe, 0x4c, 0x9d, 0xb4, 0x7f, 0xb0, 0xc0, 0xe2, 0x06, 0x62, 0x3e, - 0xa6, 0xd3, 0x7d, 0x7d, 0x1d, 0x80, 0xec, 0x0b, 0x8b, 0x04, 0x7a, 0x86, 0x2a, 0xb0, 0x62, 0x3c, - 0xdd, 0xc0, 0x6e, 0x82, 0x32, 0x09, 0x30, 0x93, 0x44, 0x1e, 0x98, 0x0d, 0x1a, 0xdb, 0x93, 0x4b, - 0x3b, 0xf3, 0x0a, 0x4b, 0xbb, 0xa4, 0x16, 0x00, 0x09, 0xce, 0x74, 0x19, 0x2b, 0xd0, 0x58, 0xed, - 0x9f, 0x2c, 0xd0, 0xd8, 0xc6, 0xb1, 0xfa, 0xb2, 0x92, 0xf8, 0x3f, 0x94, 0xf8, 0x7a, 0x70, 0x78, - 0xe4, 0xe4, 0x9e, 0x1f, 0x39, 0xb9, 0x17, 0x47, 0x8e, 0xf5, 0xd5, 0xc8, 0xb1, 0xbe, 0x1b, 0x39, - 0xd6, 0xcf, 0x23, 0xc7, 0x3a, 0x1c, 0x39, 0xd6, 0x6f, 0x23, 0xc7, 0xfa, 0x7d, 0xe4, 0xe4, 0x5e, - 0x8c, 0x1c, 0xeb, 0xd9, 0xb1, 0x93, 0x3b, 0x3c, 0x76, 0x72, 0xcf, 0x8f, 0x9d, 0xdc, 0xe7, 0xee, - 0x90, 0x9f, 0x64, 0x41, 0xf8, 0x05, 0xff, 0x10, 0xee, 0x65, 0xbf, 0x77, 0x4b, 0xba, 0xfb, 0x77, - 0xfe, 0x0c, 0x00, 0x00, 0xff, 0xff, 0x25, 0x91, 0x52, 0xd4, 0x54, 0x0c, 0x00, 0x00, + // 1148 bytes of a gzipped FileDescriptorProto + 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x56, 0x4f, 0x6f, 0x1b, 0xc5, + 0x1b, 0xf6, 0xc6, 0x7f, 0x6a, 0x8f, 0x6b, 0xd7, 0xd9, 0x36, 0xf9, 0x59, 0xfe, 0xc1, 0xc6, 0xb5, + 0x68, 0x09, 0x12, 0xac, 0x95, 0x54, 0xe2, 0xd0, 0xa2, 0x4a, 0x4d, 0x4a, 0x88, 0xa3, 0x22, 0xac, + 0x71, 0x20, 0x88, 0xcb, 0x6a, 0xb2, 0x3b, 0x76, 0x46, 0x9d, 0x9d, 0x59, 0x76, 0x66, 0xd3, 0x86, + 0x13, 0x07, 0xae, 0x48, 0xfd, 0x0e, 0x5c, 0xb8, 0x22, 0x04, 0x57, 0xae, 0x1c, 0x73, 0xec, 0x0d, + 0xe2, 0x5c, 0x90, 0xb8, 0xf4, 0x23, 0xa0, 0x99, 0x9d, 0x75, 0x62, 0x27, 0x21, 0x41, 0x3d, 0x20, + 0x6e, 0x3b, 0xef, 0x3c, 0xcf, 0x33, 0xef, 0xbc, 0xff, 0x66, 0xc1, 0x7b, 0x12, 0x87, 0x11, 0x8f, + 0x11, 0xed, 0x0a, 0x1c, 0xef, 0xe3, 0xb8, 0x8b, 0x22, 0xd2, 0x15, 0xfe, 0x1e, 0x0e, 0x12, 0x8a, + 0xbb, 0xfb, 0x2b, 0xdd, 0x10, 0x0b, 0x81, 0x46, 0xd8, 0x8d, 0x62, 0x2e, 0xb9, 0xbd, 0x94, 0xc1, + 0xdd, 0x14, 0xee, 0xa2, 0x88, 0xb8, 0x19, 0xdc, 0xdd, 0x5f, 0x69, 0xbd, 0x35, 0xd1, 0x53, 0x42, + 0x3e, 0x0f, 0x43, 0xce, 0xce, 0xc8, 0xb4, 0xee, 0x4c, 0xa1, 0x86, 0x88, 0xd0, 0x24, 0x3e, 0x7b, + 0xda, 0x8c, 0x18, 0x66, 0x49, 0x28, 0x14, 0x68, 0x72, 0xde, 0xdf, 0xa2, 0x9e, 0xf1, 0xf8, 0xe9, + 0x90, 0xf2, 0x67, 0x06, 0x75, 0x77, 0x0a, 0x75, 0xe1, 0x0d, 0x5b, 0xef, 0x4f, 0xe1, 0x32, 0x11, + 0x75, 0x5b, 0xe2, 0x6b, 0x78, 0x8c, 0xbf, 0x4c, 0xb0, 0x90, 0x5e, 0x8c, 0x45, 0xc4, 0x99, 0xc8, + 0x78, 0x4b, 0x23, 0xce, 0x47, 0x14, 0x77, 0xf5, 0x6a, 0x37, 0x19, 0x76, 0x25, 0x09, 0xb1, 0x90, + 0x28, 0x8c, 0x0c, 0xe0, 0x76, 0x80, 0x23, 0xcc, 0x02, 0xcc, 0x7c, 0x82, 0x45, 0x77, 0xc4, 0x47, + 0x5c, 0xdb, 0xf5, 0x57, 0x0a, 0xe9, 0x7c, 0x33, 0x07, 0x6a, 0x6b, 0xc9, 0x70, 0x88, 0x63, 0x1c, + 0x0c, 0x24, 0x8a, 0xa5, 0xbd, 0x0e, 0xae, 0x33, 0x1e, 0x12, 0x86, 0xa8, 0xa7, 0xf4, 0x9a, 0x56, + 0xdb, 0x5a, 0xae, 0xae, 0xb6, 0xdc, 0xf4, 0x30, 0x37, 0x3b, 0xcc, 0xdd, 0xce, 0x0e, 0x5b, 0x2b, + 0xbc, 0xf8, 0x6d, 0xc9, 0x82, 0x55, 0xc3, 0x52, 0x76, 0xfb, 0x11, 0xa8, 0x22, 0x5f, 0x26, 0x99, + 0xc6, 0xdc, 0x15, 0x35, 0x40, 0x4a, 0xd2, 0x12, 0x03, 0x50, 0xe7, 0xfb, 0x38, 0xa6, 0x28, 0xf2, + 0x22, 0x4e, 0x89, 0x7f, 0xd0, 0xcc, 0xb7, 0xad, 0xe5, 0xfa, 0xea, 0xbb, 0xee, 0xa4, 0x20, 0x54, + 0x25, 0xe8, 0xe0, 0xbb, 0xfb, 0x2b, 0xee, 0xc0, 0xc4, 0xf7, 0x93, 0x94, 0xd4, 0xd7, 0x1c, 0x58, + 0xe3, 0xa7, 0x97, 0xf6, 0x22, 0x28, 0x85, 0x88, 0x25, 0x88, 0x36, 0x0b, 0x6d, 0x6b, 0xb9, 0x0c, + 0xcd, 0xaa, 0xf3, 0x6d, 0x01, 0xd4, 0x7a, 0x4c, 0xe2, 0x98, 0x21, 0x3a, 0x90, 0x48, 0x62, 0xfb, + 0x0d, 0x50, 0x61, 0x28, 0xc4, 0x22, 0x42, 0x7e, 0x1a, 0x83, 0x0a, 0x3c, 0x31, 0xd8, 0xb7, 0xc1, + 0xf5, 0xc9, 0xc2, 0x23, 0x81, 0xbe, 0x60, 0x05, 0x56, 0x27, 0xb6, 0x5e, 0x60, 0x2f, 0x81, 0x6a, + 0x96, 0x72, 0x85, 0x28, 0x6b, 0x04, 0xc8, 0x4c, 0xbd, 0xc0, 0xee, 0x83, 0x9b, 0x14, 0x09, 0xe9, + 0x45, 0x31, 0xf7, 0xb1, 0x10, 0x38, 0x48, 0x63, 0x95, 0xbf, 0x62, 0xac, 0xe6, 0x15, 0xb9, 0x9f, + 0x71, 0x75, 0xc8, 0x76, 0xc0, 0x8d, 0x5d, 0x93, 0x4b, 0x4f, 0xa8, 0x64, 0x8a, 0x66, 0xa1, 0x9d, + 0x5f, 0xae, 0xae, 0xba, 0xee, 0x25, 0x4d, 0xe4, 0x4e, 0xd5, 0x00, 0xac, 0xef, 0x9e, 0x5e, 0x0a, + 0xfb, 0x33, 0xb0, 0xa8, 0x5d, 0xf5, 0x79, 0x18, 0x51, 0x2c, 0x09, 0x67, 0xaa, 0x16, 0x13, 0x2a, + 0x9b, 0x45, 0xed, 0x6d, 0x7b, 0x3a, 0x27, 0x69, 0x0f, 0x2a, 0xd9, 0x3e, 0x3a, 0xa0, 0x1c, 0x05, + 0x02, 0xde, 0x52, 0xfc, 0xf5, 0x09, 0x1d, 0x6a, 0xb6, 0xfd, 0x31, 0x98, 0xf7, 0x39, 0x93, 0x84, + 0x25, 0x38, 0xf0, 0x4c, 0x4f, 0x36, 0x4b, 0xe7, 0x49, 0x9a, 0x4d, 0xa5, 0xb9, 0x91, 0x7e, 0xc2, + 0xc6, 0x84, 0x6a, 0x2c, 0xf6, 0x1d, 0x50, 0xf7, 0x39, 0x1b, 0x52, 0xe2, 0x4b, 0x4f, 0xf2, 0xa7, + 0x98, 0x35, 0xaf, 0xb5, 0xad, 0xe5, 0x3c, 0xac, 0x65, 0xd6, 0x6d, 0x65, 0xd4, 0xc9, 0xc3, 0x38, + 0xf0, 0x62, 0x3c, 0x8c, 0xb1, 0xd8, 0x6b, 0x56, 0x74, 0x29, 0x54, 0x95, 0x0d, 0xa6, 0xa6, 0xce, + 0x77, 0x73, 0x60, 0x5e, 0xdf, 0x3d, 0xab, 0xaa, 0x47, 0xf1, 0x48, 0xd8, 0x0f, 0x41, 0x39, 0x8b, + 0x99, 0x69, 0x8b, 0xce, 0xb4, 0x97, 0xa7, 0x23, 0x9a, 0x31, 0xe1, 0x84, 0x63, 0xdf, 0x07, 0x05, + 0xc2, 0x86, 0xdc, 0xb4, 0xc3, 0xdd, 0xcb, 0xb9, 0x3d, 0x36, 0xe4, 0x50, 0x73, 0xec, 0x27, 0xa0, + 0x46, 0x18, 0x91, 0x04, 0x51, 0x2f, 0x42, 0xd2, 0xdf, 0x33, 0x75, 0xf2, 0xf6, 0xe5, 0x22, 0x7d, + 0x05, 0x87, 0xd7, 0x0d, 0x5b, 0xaf, 0xec, 0xc7, 0xa0, 0x28, 0x54, 0x99, 0xeb, 0x36, 0xb8, 0x4a, + 0x7d, 0x4c, 0x35, 0x07, 0x4c, 0xc9, 0x9d, 0xaf, 0xc0, 0xfc, 0x46, 0x42, 0xe9, 0xa7, 0x51, 0xa0, + 0x8c, 0xe9, 0x90, 0x7a, 0xed, 0x20, 0x9d, 0x4d, 0xe2, 0xdc, 0x39, 0x49, 0xec, 0xfc, 0x64, 0x81, + 0xc6, 0x63, 0x2c, 0xfc, 0x98, 0xec, 0x62, 0x68, 0xe6, 0xe2, 0xbf, 0x9a, 0xa0, 0xb3, 0x7e, 0xe7, + 0xcf, 0xf3, 0xfb, 0x07, 0x0b, 0xdc, 0xda, 0x51, 0x39, 0xd8, 0x31, 0x73, 0x3e, 0x8b, 0xdb, 0x47, + 0xa0, 0x82, 0x9f, 0x63, 0x3f, 0x51, 0xed, 0x61, 0x92, 0xfb, 0xce, 0x45, 0x6d, 0x95, 0x71, 0x3f, + 0xcc, 0x08, 0xf0, 0x84, 0x6b, 0xdf, 0x03, 0x8b, 0x43, 0x12, 0x0b, 0xe9, 0x4d, 0x4c, 0x5e, 0x9c, + 0x30, 0x35, 0x83, 0x0a, 0x7a, 0x06, 0xdd, 0xd4, 0xbb, 0x27, 0xd4, 0x84, 0xf5, 0x02, 0xfb, 0xff, + 0xa0, 0x42, 0x39, 0x1b, 0xa9, 0x51, 0x4b, 0x75, 0x53, 0x97, 0x61, 0x59, 0x19, 0xfa, 0x9c, 0xd2, + 0xce, 0x9f, 0x16, 0x58, 0x98, 0xf1, 0xd9, 0x04, 0x7c, 0x03, 0x94, 0x54, 0x29, 0x24, 0x42, 0x87, + 0xbb, 0x7e, 0xba, 0x90, 0xa6, 0x86, 0xf3, 0x19, 0x87, 0x07, 0x9a, 0x05, 0x0d, 0xdb, 0xbe, 0x0f, + 0x4a, 0x66, 0xa0, 0xcc, 0x5d, 0x6d, 0xa0, 0x6c, 0xe6, 0xa0, 0x61, 0xd8, 0x1f, 0x80, 0x6b, 0xd9, + 0xe8, 0xc8, 0x5f, 0x6d, 0x74, 0x6c, 0xe6, 0x60, 0x46, 0x59, 0x6b, 0x80, 0x7a, 0xaa, 0x93, 0xcd, + 0x9f, 0xce, 0x2f, 0x16, 0xb8, 0xa5, 0x7b, 0x7f, 0x36, 0x43, 0x9f, 0x83, 0x6b, 0xe6, 0x25, 0x36, + 0x5e, 0x3e, 0x9c, 0x3e, 0x68, 0xe6, 0xe5, 0xd6, 0x75, 0x72, 0x5a, 0xe7, 0x24, 0xe4, 0xa9, 0x0a, + 0xcc, 0xe4, 0xec, 0x07, 0xa0, 0x65, 0x46, 0xab, 0x1a, 0x4b, 0x48, 0x62, 0x8f, 0x92, 0x90, 0x48, + 0x4f, 0x50, 0x8c, 0x23, 0x3d, 0x10, 0xcb, 0xf0, 0x7f, 0x13, 0x04, 0x44, 0x12, 0x3f, 0x51, 0xfb, + 0x03, 0xb5, 0xbd, 0x55, 0x28, 0xe7, 0x1b, 0x85, 0xad, 0x42, 0xb9, 0xd0, 0x28, 0x6e, 0x15, 0xca, + 0xc5, 0x46, 0xa9, 0xf3, 0x1c, 0x2c, 0xcc, 0x5c, 0xc0, 0xa4, 0x6b, 0x01, 0x94, 0x4c, 0x29, 0xa4, + 0x2f, 0x5a, 0x31, 0xd6, 0xc9, 0xdf, 0x04, 0x37, 0x62, 0x8c, 0x68, 0xfa, 0x66, 0xfc, 0xb3, 0x17, + 0xbb, 0xa6, 0x88, 0xfa, 0x30, 0xb5, 0xd3, 0xf9, 0xd1, 0x02, 0x0b, 0xeb, 0x88, 0xf9, 0x98, 0xce, + 0x06, 0xef, 0x4d, 0x00, 0xb2, 0xdf, 0x18, 0x12, 0xe8, 0x44, 0x55, 0x60, 0xc5, 0x58, 0x7a, 0x81, + 0xdd, 0x02, 0x65, 0x12, 0x60, 0x26, 0x89, 0x3c, 0x30, 0x65, 0x3a, 0x59, 0x4f, 0x77, 0x46, 0xf1, + 0x35, 0x3a, 0x63, 0x51, 0x55, 0x19, 0x12, 0x9c, 0xe9, 0x90, 0x56, 0xa0, 0x59, 0x75, 0x7e, 0xb6, + 0x40, 0x73, 0x1b, 0xc7, 0xea, 0xf7, 0x45, 0xe2, 0xff, 0x90, 0xe3, 0x6b, 0xc1, 0xe1, 0x91, 0x93, + 0x7b, 0x79, 0xe4, 0xe4, 0x5e, 0x1d, 0x39, 0xd6, 0xd7, 0x63, 0xc7, 0xfa, 0x7e, 0xec, 0x58, 0xbf, + 0x8e, 0x1d, 0xeb, 0x70, 0xec, 0x58, 0xbf, 0x8f, 0x1d, 0xeb, 0x8f, 0xb1, 0x93, 0x7b, 0x35, 0x76, + 0xac, 0x17, 0xc7, 0x4e, 0xee, 0xf0, 0xd8, 0xc9, 0xbd, 0x3c, 0x76, 0x72, 0x5f, 0xb8, 0x23, 0x7e, + 0xe2, 0x05, 0xe1, 0x17, 0xfc, 0x86, 0x3f, 0xc8, 0xbe, 0x77, 0x4b, 0x3a, 0xfb, 0xf7, 0xfe, 0x0a, + 0x00, 0x00, 0xff, 0xff, 0x24, 0x92, 0x56, 0x72, 0xb9, 0x0b, 0x00, 0x00, } func (this *BufferedStart) Equal(that interface{}) bool { @@ -1240,12 +1224,6 @@ func (this *StartWorkflowRequest) Equal(that interface{}) bool { if !this.Request.Equal(that1.Request) { return false } - if !this.LastCompletionResult.Equal(that1.LastCompletionResult) { - return false - } - if !this.ContinuedFailure.Equal(that1.ContinuedFailure) { - return false - } if this.CompletedRateLimitSleep != that1.CompletedRateLimitSleep { return false } @@ -1482,17 +1460,11 @@ func (this *StartWorkflowRequest) GoString() string { if this == nil { return "nil" } - s := make([]string, 0, 8) + s := make([]string, 0, 6) s = append(s, "&schedule.StartWorkflowRequest{") if this.Request != nil { s = append(s, "Request: "+fmt.Sprintf("%#v", this.Request)+",\n") } - if this.LastCompletionResult != nil { - s = append(s, "LastCompletionResult: "+fmt.Sprintf("%#v", this.LastCompletionResult)+",\n") - } - if this.ContinuedFailure != nil { - s = append(s, "ContinuedFailure: "+fmt.Sprintf("%#v", this.ContinuedFailure)+",\n") - } s = append(s, "CompletedRateLimitSleep: "+fmt.Sprintf("%#v", this.CompletedRateLimitSleep)+",\n") s = append(s, "}") return strings.Join(s, "") @@ -2035,30 +2007,6 @@ func (m *StartWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) { i-- dAtA[i] = 0x30 } - if m.ContinuedFailure != nil { - { - size, err := m.ContinuedFailure.MarshalToSizedBuffer(dAtA[:i]) - if err != nil { - return 0, err - } - i -= size - i = encodeVarintMessage(dAtA, i, uint64(size)) - } - i-- - dAtA[i] = 0x2a - } - if m.LastCompletionResult != nil { - { - size, err := m.LastCompletionResult.MarshalToSizedBuffer(dAtA[:i]) - if err != nil { - return 0, err - } - i -= size - i = encodeVarintMessage(dAtA, i, uint64(size)) - } - i-- - dAtA[i] = 0x22 - } if m.Request != nil { { size, err := m.Request.MarshalToSizedBuffer(dAtA[:i]) @@ -2095,12 +2043,12 @@ func (m *StartWorkflowResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) { var l int _ = l if m.RealStartTime != nil { - n19, err19 := github_com_gogo_protobuf_types.StdTimeMarshalTo(*m.RealStartTime, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(*m.RealStartTime):]) - if err19 != nil { - return 0, err19 + n17, err17 := github_com_gogo_protobuf_types.StdTimeMarshalTo(*m.RealStartTime, dAtA[i-github_com_gogo_protobuf_types.SizeOfStdTime(*m.RealStartTime):]) + if err17 != nil { + return 0, err17 } - i -= n19 - i = encodeVarintMessage(dAtA, i, uint64(n19)) + i -= n17 + i = encodeVarintMessage(dAtA, i, uint64(n17)) i-- dAtA[i] = 0x12 } @@ -2435,14 +2383,6 @@ func (m *StartWorkflowRequest) Size() (n int) { l = m.Request.Size() n += 1 + l + sovMessage(uint64(l)) } - if m.LastCompletionResult != nil { - l = m.LastCompletionResult.Size() - n += 1 + l + sovMessage(uint64(l)) - } - if m.ContinuedFailure != nil { - l = m.ContinuedFailure.Size() - n += 1 + l + sovMessage(uint64(l)) - } if m.CompletedRateLimitSleep { n += 2 } @@ -2643,8 +2583,6 @@ func (this *StartWorkflowRequest) String() string { } s := strings.Join([]string{`&StartWorkflowRequest{`, `Request:` + strings.Replace(fmt.Sprintf("%v", this.Request), "StartWorkflowExecutionRequest", "v14.StartWorkflowExecutionRequest", 1) + `,`, - `LastCompletionResult:` + strings.Replace(fmt.Sprintf("%v", this.LastCompletionResult), "Payloads", "v11.Payloads", 1) + `,`, - `ContinuedFailure:` + strings.Replace(fmt.Sprintf("%v", this.ContinuedFailure), "Failure", "v12.Failure", 1) + `,`, `CompletedRateLimitSleep:` + fmt.Sprintf("%v", this.CompletedRateLimitSleep) + `,`, `}`, }, "") @@ -3986,78 +3924,6 @@ func (m *StartWorkflowRequest) Unmarshal(dAtA []byte) error { return err } iNdEx = postIndex - case 4: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field LastCompletionResult", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowMessage - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthMessage - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthMessage - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.LastCompletionResult == nil { - m.LastCompletionResult = &v11.Payloads{} - } - if err := m.LastCompletionResult.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex - case 5: - if wireType != 2 { - return fmt.Errorf("proto: wrong wireType = %d for field ContinuedFailure", wireType) - } - var msglen int - for shift := uint(0); ; shift += 7 { - if shift >= 64 { - return ErrIntOverflowMessage - } - if iNdEx >= l { - return io.ErrUnexpectedEOF - } - b := dAtA[iNdEx] - iNdEx++ - msglen |= int(b&0x7F) << shift - if b < 0x80 { - break - } - } - if msglen < 0 { - return ErrInvalidLengthMessage - } - postIndex := iNdEx + msglen - if postIndex < 0 { - return ErrInvalidLengthMessage - } - if postIndex > l { - return io.ErrUnexpectedEOF - } - if m.ContinuedFailure == nil { - m.ContinuedFailure = &v12.Failure{} - } - if err := m.ContinuedFailure.Unmarshal(dAtA[iNdEx:postIndex]); err != nil { - return err - } - iNdEx = postIndex case 6: if wireType != 0 { return fmt.Errorf("proto: wrong wireType = %d for field CompletedRateLimitSleep", wireType) diff --git a/common/util.go b/common/util.go index 34473e0f981..4a8c7752f6f 100644 --- a/common/util.go +++ b/common/util.go @@ -560,7 +560,10 @@ func FromConfigToDefaultRetrySettings(options map[string]interface{}) DefaultRet return defaultSettings } -// CreateHistoryStartWorkflowRequest create a start workflow request for history +// CreateHistoryStartWorkflowRequest create a start workflow request for history. +// Note: this mutates startRequest by unsetting the fields ContinuedFailure and +// LastCompletionResult (these should only be set on workflows created by the scheduler +// worker). func CreateHistoryStartWorkflowRequest( namespaceID string, startRequest *workflowservice.StartWorkflowExecutionRequest, @@ -574,7 +577,11 @@ func CreateHistoryStartWorkflowRequest( Attempt: 1, ParentExecutionInfo: parentExecutionInfo, FirstWorkflowTaskBackoff: backoff.GetBackoffForNextScheduleNonNegative(startRequest.GetCronSchedule(), now, now), + ContinuedFailure: startRequest.ContinuedFailure, + LastCompletionResult: startRequest.LastCompletionResult, } + startRequest.ContinuedFailure = nil + startRequest.LastCompletionResult = nil if timestamp.DurationValue(startRequest.GetWorkflowExecutionTimeout()) > 0 { deadline := now.Add(timestamp.DurationValue(startRequest.GetWorkflowExecutionTimeout())) diff --git a/go.mod b/go.mod index bc270c8fcdd..4ef54f033b7 100644 --- a/go.mod +++ b/go.mod @@ -44,7 +44,7 @@ require ( go.opentelemetry.io/otel/metric v0.34.0 go.opentelemetry.io/otel/sdk v1.11.2 go.opentelemetry.io/otel/sdk/metric v0.34.0 - go.temporal.io/api v1.16.0 + go.temporal.io/api v1.16.1-0.20230210062249-90fb5b4a7b41 go.temporal.io/sdk v1.21.0 go.temporal.io/version v0.3.0 go.uber.org/atomic v1.10.0 @@ -52,10 +52,10 @@ require ( go.uber.org/multierr v1.8.0 go.uber.org/zap v1.24.0 golang.org/x/exp v0.0.0-20221126150942-6ab00d035af9 - golang.org/x/oauth2 v0.2.0 + golang.org/x/oauth2 v0.4.0 golang.org/x/time v0.2.0 google.golang.org/api v0.103.0 - google.golang.org/grpc v1.52.3 + google.golang.org/grpc v1.53.0 google.golang.org/grpc/examples v0.0.0-20221201195934-736197138d20 gopkg.in/square/go-jose.v2 v2.6.0 gopkg.in/validator.v2 v2.0.1 @@ -65,15 +65,15 @@ require ( require ( cloud.google.com/go v0.107.0 // indirect - cloud.google.com/go/compute v1.13.0 // indirect - cloud.google.com/go/compute/metadata v0.2.2 // indirect + cloud.google.com/go/compute v1.15.1 // indirect + cloud.google.com/go/compute/metadata v0.2.3 // indirect cloud.google.com/go/iam v0.8.0 // indirect github.com/apache/thrift v0.17.0 // indirect github.com/benbjohnson/clock v1.3.0 // indirect github.com/beorn7/perks v1.0.1 // indirect github.com/bitly/go-hostpool v0.1.0 // indirect github.com/cenkalti/backoff/v4 v4.2.0 // indirect - github.com/cespare/xxhash/v2 v2.1.2 // indirect + github.com/cespare/xxhash/v2 v2.2.0 // indirect github.com/cpuguy83/go-md2man/v2 v2.0.2 // indirect github.com/davecgh/go-spew v1.1.1 // indirect github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a // indirect @@ -121,13 +121,13 @@ require ( go.uber.org/dig v1.15.0 // indirect golang.org/x/crypto v0.3.0 // indirect golang.org/x/mod v0.7.0 // indirect - golang.org/x/net v0.5.0 // indirect - golang.org/x/sys v0.4.0 // indirect - golang.org/x/text v0.6.0 // indirect + golang.org/x/net v0.6.0 // indirect + golang.org/x/sys v0.5.0 // indirect + golang.org/x/text v0.7.0 // indirect golang.org/x/tools v0.3.0 // indirect golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2 // indirect google.golang.org/appengine v1.6.7 // indirect - google.golang.org/genproto v0.0.0-20230127162408-596548ed4efa // indirect + google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc // indirect google.golang.org/protobuf v1.28.1 // indirect gopkg.in/inf.v0 v0.9.1 // indirect lukechampine.com/uint128 v1.2.0 // indirect diff --git a/go.sum b/go.sum index 636f4097a2c..4f3b946c478 100644 --- a/go.sum +++ b/go.sum @@ -3,6 +3,7 @@ cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMT cloud.google.com/go v0.38.0/go.mod h1:990N+gfupTy94rShfmMCWGDn0LpTmnzTp2qbd1dvSRU= cloud.google.com/go v0.44.1/go.mod h1:iSa0KzasP4Uvy3f1mN/7PiObzGgflwredwwASm/v6AU= cloud.google.com/go v0.44.2/go.mod h1:60680Gw3Yr4ikxnPRS/oxxkBccT6SA1yMk63TGekxKY= +cloud.google.com/go v0.44.3/go.mod h1:60680Gw3Yr4ikxnPRS/oxxkBccT6SA1yMk63TGekxKY= cloud.google.com/go v0.45.1/go.mod h1:RpBamKRgapWJb87xiFSdk4g1CME7QZg3uwTez+TSTjc= cloud.google.com/go v0.46.3/go.mod h1:a6bKKbmY7er1mI7TEI4lsAkts/mkhTSZK8w33B4RAg0= cloud.google.com/go v0.50.0/go.mod h1:r9sluTvynVuxRIOHXQEHMFffphuXHOMZMycpNR5e6To= @@ -15,6 +16,7 @@ cloud.google.com/go v0.62.0/go.mod h1:jmCYTdRCQuc1PHIIJ/maLInMho30T/Y0M4hTdTShOY cloud.google.com/go v0.65.0/go.mod h1:O5N8zS7uWy9vkA9vayVHs65eM1ubvY4h553ofrNHObY= cloud.google.com/go v0.72.0/go.mod h1:M+5Vjvlc2wnp6tjzE102Dw08nGShTscUx2nZMufOKPI= cloud.google.com/go v0.74.0/go.mod h1:VV1xSbzvo+9QJOxLDaJfTjx5e+MePCpCWwvftOeQmWk= +cloud.google.com/go v0.75.0/go.mod h1:VGuuCn7PG0dwsd5XPVm2Mm3wlh3EL55/79EKB6hlPTY= cloud.google.com/go v0.78.0/go.mod h1:QjdrLG0uq+YwhjoVOLsS1t7TW8fs36kLs4XO5R5ECHg= cloud.google.com/go v0.79.0/go.mod h1:3bzgcEeQlzbuEAYu4mrWhKqWjmpprinYgKJLgKHnbb8= cloud.google.com/go v0.81.0/go.mod h1:mk/AM35KwGk/Nm2YSeZbxXdrNK3KZOYHmLkOqC2V6E0= @@ -113,12 +115,15 @@ cloud.google.com/go/compute v1.7.0/go.mod h1:435lt8av5oL9P3fv1OEzSbSUe+ybHXGMPQH cloud.google.com/go/compute v1.10.0/go.mod h1:ER5CLbMxl90o2jtNbGSbtfOpQKR0t15FOtRsugnLrlU= cloud.google.com/go/compute v1.12.0/go.mod h1:e8yNOBcBONZU1vJKCvCoDw/4JQsA0dpM4x/6PIIOocU= cloud.google.com/go/compute v1.12.1/go.mod h1:e8yNOBcBONZU1vJKCvCoDw/4JQsA0dpM4x/6PIIOocU= -cloud.google.com/go/compute v1.13.0 h1:AYrLkB8NPdDRslNp4Jxmzrhdr03fUAIDbiGFjLWowoU= cloud.google.com/go/compute v1.13.0/go.mod h1:5aPTS0cUNMIc1CE546K+Th6weJUNQErARyZtRXDJ8GE= +cloud.google.com/go/compute v1.14.0/go.mod h1:YfLtxrj9sU4Yxv+sXzZkyPjEyPBZfXHUvjxega5vAdo= +cloud.google.com/go/compute v1.15.1 h1:7UGq3QknM33pw5xATlpzeoomNxsacIVvTqTTvbfajmE= +cloud.google.com/go/compute v1.15.1/go.mod h1:bjjoF/NtFUrkD/urWfdHaKuOPDR5nWIs63rR+SXhcpA= cloud.google.com/go/compute/metadata v0.1.0/go.mod h1:Z1VN+bulIf6bt4P/C37K4DyZYZEXYonfTBHHFPO/4UU= +cloud.google.com/go/compute/metadata v0.2.0/go.mod h1:zFmK7XCadkQkj6TtorcaGlCW1hT1fIilQDwofLpJ20k= cloud.google.com/go/compute/metadata v0.2.1/go.mod h1:jgHgmJd2RKBGzXqF5LR2EZMGxBkeanZ9wwa75XHJgOM= -cloud.google.com/go/compute/metadata v0.2.2 h1:aWKAjYaBaOSrpKl57+jnS/3fJRQnxL7TvR/u1VVbt6k= -cloud.google.com/go/compute/metadata v0.2.2/go.mod h1:jgHgmJd2RKBGzXqF5LR2EZMGxBkeanZ9wwa75XHJgOM= +cloud.google.com/go/compute/metadata v0.2.3 h1:mg4jlk7mCAj6xXp9UJ4fjI9VUI5rubuGBW5aJ7UnBMY= +cloud.google.com/go/compute/metadata v0.2.3/go.mod h1:VAV5nSsACxMJvgaAuX6Pk2AawlZn8kiOGuCv6gTkwuA= cloud.google.com/go/contactcenterinsights v1.3.0/go.mod h1:Eu2oemoePuEFc/xKFPjbTuPSj0fYJcPls9TFlPNnHHY= cloud.google.com/go/contactcenterinsights v1.4.0/go.mod h1:L2YzkGbPsv+vMQMCADxJoT9YiTTnSEd6fEvCeHTYVck= cloud.google.com/go/container v1.6.0/go.mod h1:Xazp7GjJSeUYo688S+6J5V+n/t+G5sKBTFkKNudGRxg= @@ -340,6 +345,7 @@ cloud.google.com/go/storage v1.5.0/go.mod h1:tpKbwo567HUNpVclU5sGELwQWBDZ8gh0Zeo cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohlUTyfDhBk= cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs= cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0= +cloud.google.com/go/storage v1.14.0/go.mod h1:GrKmX003DSIwi9o29oFT7YDnHYwZoctc3fOKtUw0Xmo= cloud.google.com/go/storage v1.22.1/go.mod h1:S8N1cAStu7BOeFfE8KAQzmyyLkK8p/vmRq6kuBTW58Y= cloud.google.com/go/storage v1.23.0/go.mod h1:vOEEDNFnciUMhBeT6hsJIn3ieU5cFRmzeLgDvXzfIXc= cloud.google.com/go/storage v1.27.0/go.mod h1:x9DOL8TK/ygDUMieqwfhdpQryTeEkhGKMi80i/iqR2s= @@ -428,10 +434,12 @@ github.com/cenkalti/backoff/v4 v4.2.0 h1:HN5dHm3WBOgndBH6E8V0q2jIYIR3s9yglV8k/+M github.com/cenkalti/backoff/v4 v4.2.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE= github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= github.com/census-instrumentation/opencensus-proto v0.3.0/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= +github.com/census-instrumentation/opencensus-proto v0.4.1/go.mod h1:4T9NM4+4Vw91VeyqjLS6ao50K5bOcLKN6Q42XnYaRYw= github.com/cespare/xxhash v1.1.0/go.mod h1:XrSqR1VqqWfGrhpAt58auRo0WTKS1nRRg3ghfAqPWnc= github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= -github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE= github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44= +github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI= github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI= github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU= @@ -440,11 +448,14 @@ github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGX github.com/cncf/udpa/go v0.0.0-20200629203442-efcf912fb354/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk= github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk= github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI= +github.com/cncf/udpa/go v0.0.0-20220112060539-c52dc94e7fbe/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI= github.com/cncf/xds/go v0.0.0-20210312221358-fbca930ec8ed/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20210805033703-aa0b78936158/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20211001041855-01bcc9b48dfe/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20220314180256-7f1daf1720fc/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20230105202645-06c439db220b/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU= github.com/cpuguy83/go-md2man/v2 v2.0.1/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o= github.com/cpuguy83/go-md2man/v2 v2.0.2 h1:p1EgwI/C7NhT0JmVkwCD2ZBK8j4aeHQX2pMHHBfMQ6w= @@ -469,7 +480,10 @@ github.com/envoyproxy/go-control-plane v0.9.9-0.20210217033140-668b12f5399d/go.m github.com/envoyproxy/go-control-plane v0.9.9-0.20210512163311-63b5d3c536b0/go.mod h1:hliV/p42l8fGbc6Y9bQ70uLwIvmJyVE5k4iMKlh8wCQ= github.com/envoyproxy/go-control-plane v0.9.10-0.20210907150352-cf90f659a021/go.mod h1:AFq3mo9L8Lqqiid3OhADV3RfLJnjiw63cSpi+fDTRC0= github.com/envoyproxy/go-control-plane v0.10.2-0.20220325020618-49ff273808a1/go.mod h1:KJwIaB5Mv44NWtYuAOFCVOjcI94vtpEz2JU/D2v6IjE= +github.com/envoyproxy/go-control-plane v0.10.3/go.mod h1:fJJn/j26vwOu972OllsvAgJJM//w9BV6Fxbg2LuVd34= github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= +github.com/envoyproxy/protoc-gen-validate v0.6.7/go.mod h1:dyJXwwfPK2VSqiB9Klm1J6romD608Ba7Hij42vrOBCo= +github.com/envoyproxy/protoc-gen-validate v0.9.1/go.mod h1:OKNgG7TCp5pF4d6XftA0++PMirau2/yoOwVac3AbF2w= github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a h1:yDWHCSQ40h88yih2JAcL6Ls/kVkSE8GFACTGVnMPruw= github.com/facebookgo/clock v0.0.0-20150410010913-600d898af40a/go.mod h1:7Ga40egUymuWXxAe151lTNnCv97MddSOVsjpPPkityA= github.com/fatih/color v1.13.0 h1:8LOYc1KYPPmyKMuN8QV2DNRWNbLo6LZ0iLs8+mlH53w= @@ -582,6 +596,7 @@ github.com/google/pprof v0.0.0-20200430221834-fc25d7d30c6d/go.mod h1:ZgVRPoUq/hf github.com/google/pprof v0.0.0-20200708004538-1a94d8640e99/go.mod h1:ZgVRPoUq/hfqzAqh7sHMqb3I9Rq5C59dIz2SbBwJ4eM= github.com/google/pprof v0.0.0-20201023163331-3e6fc7fc9c4c/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/pprof v0.0.0-20201203190320-1bf35d6f28c2/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= +github.com/google/pprof v0.0.0-20201218002935-b9804c9f04c2/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/pprof v0.0.0-20210122040257-d980be63207e/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/pprof v0.0.0-20210226084205-cbba55b83ad5/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/pprof v0.0.0-20210601050228-01bbb1931b22/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= @@ -609,10 +624,12 @@ github.com/googleapis/gax-go/v2 v2.6.0/go.mod h1:1mjbznJAPHFpesgE5ucqfYEscaz5kMd github.com/googleapis/gax-go/v2 v2.7.0 h1:IcsPKeInNvYi7eqSaDjiZqDDKu5rsmunY0Y1YupQSSQ= github.com/googleapis/gax-go/v2 v2.7.0/go.mod h1:TEop28CZZQ2y+c0VxMUmu1lV+fQx57QpBWsYpwqHJx8= github.com/googleapis/go-type-adapters v1.0.0/go.mod h1:zHW75FOG2aur7gAO2B+MLby+cLsWGBF62rFAi7WjWO4= +github.com/googleapis/google-cloud-go-testing v0.0.0-20200911160855-bcd43fbb19e8/go.mod h1:dvDLG8qkwmyD9a/MJJN3XJcT3xFxOKAvTZGvuZmac9g= github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 h1:+9834+KizmvFV7pXQGSXQTsaWhq2GjuNUt0aUU0YBYw= github.com/grpc-ecosystem/go-grpc-middleware v1.3.0/go.mod h1:z0ButlSOZa5vEBq9m2m2hlwIgKw+rp3sdCBRoJY+30Y= github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= github.com/grpc-ecosystem/grpc-gateway/v2 v2.7.0/go.mod h1:hgWBS7lorOAVIJEQMi4ZsPv9hVvWI6+ch50m39Pf2Ks= +github.com/grpc-ecosystem/grpc-gateway/v2 v2.11.3/go.mod h1:o//XUCC/F+yRGJoPO/VU0GSB0f8Nhgmxx0VIRUvaC0w= github.com/grpc-ecosystem/grpc-gateway/v2 v2.14.0 h1:t7uX3JBHdVwAi3G7sSSdbsk8NfgA+LnUS88V/2EKaA0= github.com/grpc-ecosystem/grpc-gateway/v2 v2.14.0/go.mod h1:4OGVnY4qf2+gw+ssiHbW+pq4mo2yko94YxxMmXZ7jCA= github.com/hailocab/go-hostpool v0.0.0-20160125115350-e80d13ce29ed h1:5upAirOpQc1Q53c0bnx2ufif5kANL7bfZWcc6VJWJd8= @@ -652,6 +669,7 @@ github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+o github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= +github.com/kr/fs v0.1.0/go.mod h1:FFnZGqtBN9Gxj7eW1uZ42v5BccTP0vu6NEaFoC2HwRg= github.com/kr/logfmt v0.0.0-20140226030751-b84e30acd515/go.mod h1:+0opPa2QZZtGFBFZlji/RkVcI2GknAs/DXo4wKdlNEc= github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI= @@ -662,6 +680,8 @@ github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.10.7 h1:p7ZhMD+KsSRozJr34udlUrhboJwWAgCg34+/ZZNvZZw= github.com/lib/pq v1.10.7/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o= +github.com/lyft/protoc-gen-star v0.6.0/go.mod h1:TGAoBVkt8w7MPG72TrKIu85MIdXwDuzJYeZuUPFPNwA= +github.com/lyft/protoc-gen-star v0.6.1/go.mod h1:TGAoBVkt8w7MPG72TrKIu85MIdXwDuzJYeZuUPFPNwA= github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= github.com/mattn/go-colorable v0.1.9/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc= @@ -700,6 +720,8 @@ github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINE github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= +github.com/pkg/sftp v1.10.1/go.mod h1:lYOWFsE0bwd1+KfKJaKeuokY15vzFx25BLbzYYoAxZI= +github.com/pkg/sftp v1.13.1/go.mod h1:3HaPG6Dq1ILlpPZRO0HVMrsydcdLt6HRDccSgb87qRg= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/prashantv/protectmem v0.0.0-20171002184600-e20412882b3a h1:AA9vgIBDjMHPC2McaGPojgV2dcI78ZC0TLNhYCXEKH8= @@ -757,6 +779,9 @@ github.com/sirupsen/logrus v1.6.0/go.mod h1:7uNnSEd1DgxDLC74fIahvMZmmYsHGZGEOFrf github.com/sirupsen/logrus v1.9.0 h1:trlNQbNUG3OdDrDil03MCb1H2o9nJ1x4/5LYw7byDE0= github.com/sirupsen/logrus v1.9.0/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ= github.com/spaolacci/murmur3 v0.0.0-20180118202830-f09979ecbc72/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA= +github.com/spf13/afero v1.3.3/go.mod h1:5KUK8ByomD5Ti5Artl0RtHeI5pTF7MIDuXL3yY520V4= +github.com/spf13/afero v1.6.0/go.mod h1:Ai8FlHk4v/PARR026UzYexafAt9roJ7LcLMAmO6Z93I= +github.com/spf13/afero v1.9.2/go.mod h1:iUV7ddyEEZPO5gA3zD4fJt6iStLlL+Lg4m2cihcDf8Y= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= @@ -838,10 +863,12 @@ go.opentelemetry.io/otel/sdk/metric v0.34.0/go.mod h1:l4r16BIqiqPy5rd14kkxllPy/f go.opentelemetry.io/otel/trace v1.11.2 h1:Xf7hWSF2Glv0DE3MH7fBHvtpSBsjcBUe5MYAmZM/+y0= go.opentelemetry.io/otel/trace v1.11.2/go.mod h1:4N+yC7QEz7TTsG9BSRLNAa63eg5E06ObSbKPmxQ/pKA= go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= +go.opentelemetry.io/proto/otlp v0.15.0/go.mod h1:H7XAot3MsfNsj7EXtrA2q5xSNQ10UqI405h3+duxN4U= go.opentelemetry.io/proto/otlp v0.19.0 h1:IVN6GR+mhC4s5yfcTbmzHYODqvWAp3ZedA2SJPI1Nnw= go.opentelemetry.io/proto/otlp v0.19.0/go.mod h1:H7XAot3MsfNsj7EXtrA2q5xSNQ10UqI405h3+duxN4U= -go.temporal.io/api v1.16.0 h1:L7TQrUF9LxEWpmzwAQNJvaFjRD/nfCKooxTnyk0u/Ec= go.temporal.io/api v1.16.0/go.mod h1:u3qLbaVTffmcZQbf9ueB+16LKmhkftH79SJOV517MDk= +go.temporal.io/api v1.16.1-0.20230210062249-90fb5b4a7b41 h1:Sa/a1lh4GpWDqP7JLz5VApkd9+bXH4G+8wdsgnYlS7U= +go.temporal.io/api v1.16.1-0.20230210062249-90fb5b4a7b41/go.mod h1:sCN2tPg4ZlrE0GDp8o1X40MBP7X4C9c7p7lzVS18qeU= go.temporal.io/sdk v1.21.0 h1:nBWUAhl3ZWeOjvK1lesi8HgXU5Z9KQ6v0d9ooNWK0ZU= go.temporal.io/sdk v1.21.0/go.mod h1:Pq3Mp7p0lWNFM+YS2guBy8V/lJySh329AcyS+Wj/Wmo= go.temporal.io/version v0.3.0 h1:dMrei9l9NyHt8nG6EB8vAwDLLTwx2SvRyucCSumAiig= @@ -871,9 +898,12 @@ golang.org/x/crypto v0.0.0-20180904163835-0709b304e793/go.mod h1:6SG95UA2DQfeDnf golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20190605123033-f99c8df09eb5/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= +golang.org/x/crypto v0.0.0-20190820162420-60c769a6c586/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= +golang.org/x/crypto v0.0.0-20210421170649-83a5a9bb288b/go.mod h1:T9bdIzuCu7OtxOm1hfPfRQxPLYneinmdGuTeoZ9dtd4= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= +golang.org/x/crypto v0.0.0-20211108221036-ceb1ce70b4fa/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= golang.org/x/crypto v0.3.0 h1:a06MkbcxBrEFc0w0QIZWXrH/9cCX6KJyWbBOIwAn+7A= golang.org/x/crypto v0.3.0/go.mod h1:hebNnKkNXi2UzZN1eVRvBB7co0a+JxK6XbPiWVs/3J4= golang.org/x/exp v0.0.0-20180321215751-8460e604b9de/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= @@ -917,6 +947,7 @@ golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.1/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA= +golang.org/x/mod v0.5.0/go.mod h1:5OXOZSfqPIIbmVBIIKWRFfZjPR0E5r58TLhUjH0a2Ro= golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/mod v0.7.0 h1:LapD9S96VoQRhi/GrNTqeBJFrUjs5UHCAtTlgwA5oZA= golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= @@ -952,12 +983,14 @@ golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwY golang.org/x/net v0.0.0-20201031054903-ff519b6c9102/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= golang.org/x/net v0.0.0-20201110031124-69a78807bb2b/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= golang.org/x/net v0.0.0-20201209123823-ac852fbbde11/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.0.0-20201224014010-6772e930b67b/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20210119194325-5f4716e94777/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20210316092652-d523dce5a7f4/go.mod h1:RBQZq4jEuRlivfhVLdyRGr576XBO4/greRjx4P4O3yc= golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM= golang.org/x/net v0.0.0-20210503060351-7fd8e65b6420/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20210525063256-abc453219eb5/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= +golang.org/x/net v0.0.0-20210813160813-60bc85c4be6d/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211015210444-4f30a5c0130f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= golang.org/x/net v0.0.0-20220225172249-27dd8689420f/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= @@ -972,9 +1005,11 @@ golang.org/x/net v0.0.0-20220909164309-bea034e7d591/go.mod h1:YDH+HFinaLZZlnHAfS golang.org/x/net v0.0.0-20221012135044-0b7e1fb9d458/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk= golang.org/x/net v0.0.0-20221014081412-f15817d10f9b/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk= golang.org/x/net v0.1.0/go.mod h1:Cx3nUiGt4eDBEyega/BKRp+/AlGL8hYe7U9odMt2Cco= +golang.org/x/net v0.2.0/go.mod h1:KqCZLdyyvdV855qA2rE3GC2aiw5xGR5TEjj8smXukLY= golang.org/x/net v0.4.0/go.mod h1:MBQ8lrhLObU/6UmLb4fmbmk5OcyYmqtbGd/9yIeKjEE= -golang.org/x/net v0.5.0 h1:GyT4nK/YDHSqa1c4753ouYCDajOYKTja9Xb/OHtgvSw= golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws= +golang.org/x/net v0.6.0 h1:L4ZwwTvKW9gr0ZMS1yrHD9GZhIuVjOBBnaKH+SPQK0Q= +golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -1000,8 +1035,8 @@ golang.org/x/oauth2 v0.0.0-20220822191816-0ebed06d0094/go.mod h1:h4gKUeWbJ4rQPri golang.org/x/oauth2 v0.0.0-20220909003341-f21342109be1/go.mod h1:h4gKUeWbJ4rQPri7E0u6Gs4e9Ri2zaLxzw5DI5XGrYg= golang.org/x/oauth2 v0.0.0-20221006150949-b44042a4b9c1/go.mod h1:h4gKUeWbJ4rQPri7E0u6Gs4e9Ri2zaLxzw5DI5XGrYg= golang.org/x/oauth2 v0.0.0-20221014153046-6fdb5e3db783/go.mod h1:h4gKUeWbJ4rQPri7E0u6Gs4e9Ri2zaLxzw5DI5XGrYg= -golang.org/x/oauth2 v0.2.0 h1:GtQkldQ9m7yvzCL1V+LrYow3Khe0eJH0w7RbX/VbaIU= -golang.org/x/oauth2 v0.2.0/go.mod h1:Cwn6afJ8jrQwYMxQDTpISoXmXW9I6qF6vDeuuoX3Ibs= +golang.org/x/oauth2 v0.4.0 h1:NF0gk8LVPg1Ml7SSbGyySuoxdsXitj7TvgvuRxIMc/M= +golang.org/x/oauth2 v0.4.0/go.mod h1:RznEsdpjGAINPTOF0UH/t+xJ75L18YO3Ho6Pyn+uRec= golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= @@ -1058,11 +1093,13 @@ golang.org/x/sys v0.0.0-20210104204734-6f8348627aad/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20210119212857-b64e53b001e4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210220050731-9a76102bfb43/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210225134936-a50acf3fe073/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210305230114-8fe3ee5dd75b/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210315160823-c6e025ad8005/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210320140829-1e4c9ba3b0c4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210423185535-09eb48e85fd7/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210514084401-e8d321eab015/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210603081109-ebe580a85c40/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -1071,6 +1108,7 @@ golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20210616094352-59db8d763f22/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210806184541-e5e7981a1069/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.0.0-20210816183151-1e6c022a8912/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210823070655-63515b42dcdf/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210908233432-aa78b53d3365/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20211019181941-9d821ace8654/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -1094,14 +1132,18 @@ golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220728004956-3c1f35247d10/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.2.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.3.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.4.0 h1:Zr2JFtRQNX3BCZ8YtxRE9hNJYC8J6I1MVbMg6owUp18= golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.5.0 h1:MUK/U/4lj1t1oPg0HfuXDN/Z1wv31ZJ/YcPiGccS4DU= +golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= golang.org/x/term v0.1.0/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= +golang.org/x/term v0.2.0/go.mod h1:TVmDHMZPmdnySmBfhjOoOdhjzdE1h4u1VwSiw2l1Nuc= golang.org/x/term v0.3.0/go.mod h1:q750SLmJuPmVoN1blW3UFBPREJfb1KmY3vwxfr+nFDA= golang.org/x/term v0.4.0/go.mod h1:9P2UbLfCdcvo3p/nzKvsmas4TnlujnuoV9hGgYzW1lQ= +golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= golang.org/x/text v0.0.0-20170915032832-14c0d48ead0c/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= @@ -1114,8 +1156,9 @@ golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.3.8/go.mod h1:E6s5w1FMmriuDzIBO73fBruAKo1PCIq6d2Q6DHfQ8WQ= golang.org/x/text v0.4.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/text v0.5.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= -golang.org/x/text v0.6.0 h1:3XmdazWV+ubf7QgHSTWeykHOci5oeekaGJBLkrkaw4k= golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= +golang.org/x/text v0.7.0 h1:4BRB4x83lYWy72KwLD/qYDuTu7q9PjSagHvijDw7cLo= +golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/time v0.0.0-20181108054448-85acf8d2951c/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= @@ -1174,6 +1217,7 @@ golang.org/x/tools v0.0.0-20201201161351-ac6f37ff4c2a/go.mod h1:emZCQorbCU4vsT4f golang.org/x/tools v0.0.0-20201208233053-a543418bbed2/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/tools v0.0.0-20210105154028-b0ab187a4818/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= +golang.org/x/tools v0.0.0-20210108195828-e2f9c7f1fc8e/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA= golang.org/x/tools v0.1.0/go.mod h1:xkSsbof2nBLbhDlRMhhhyNLN/zl3eTqcnHD5viDpcZ0= golang.org/x/tools v0.1.1/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= golang.org/x/tools v0.1.2/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk= @@ -1293,7 +1337,9 @@ google.golang.org/genproto v0.0.0-20201109203340-2640f1f9cdfb/go.mod h1:FWY/as6D google.golang.org/genproto v0.0.0-20201201144952-b05cb90ed32e/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20201210142538-e3217bee35cc/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20201214200347-8c77b98c765d/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= +google.golang.org/genproto v0.0.0-20210108203827-ffc7fda8c3d7/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20210222152913-aa3ee6e6a81c/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= +google.golang.org/genproto v0.0.0-20210226172003-ab064af71705/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20210303154014-9728d6b83eeb/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20210310155132-4ce2db91004e/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20210319143718-93e7006c17a6/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= @@ -1326,6 +1372,7 @@ google.golang.org/genproto v0.0.0-20220222213610-43724f9ea8cf/go.mod h1:kGP+zUP2 google.golang.org/genproto v0.0.0-20220304144024-325a89244dc8/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220310185008-1973136f34c6/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220324131243-acbaeb5b85eb/go.mod h1:hAL49I2IFola2sVEjAn7MEwsja0xp51I0tlGAf9hz4E= +google.golang.org/genproto v0.0.0-20220329172620-7be39ac1afc7/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/genproto v0.0.0-20220407144326-9054f6ed7bac/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/genproto v0.0.0-20220413183235-5e96e2839df9/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/genproto v0.0.0-20220414192740-2d67ff6cf2b4/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= @@ -1365,8 +1412,11 @@ google.golang.org/genproto v0.0.0-20221114212237-e4508ebdbee1/go.mod h1:rZS5c/ZV google.golang.org/genproto v0.0.0-20221117204609-8f9c96812029/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= google.golang.org/genproto v0.0.0-20221201164419-0e50fba7f41c/go.mod h1:rZS5c/ZVYMaOGBfO68GWtjOw/eLaZM1X6iVtgjZ+EWg= -google.golang.org/genproto v0.0.0-20230127162408-596548ed4efa h1:GZXdWYIKckxQE2EcLHLvF+KLF+bIwoxGdMUxTZizueg= +google.golang.org/genproto v0.0.0-20221202195650-67e5cbc046fd/go.mod h1:cTsE614GARnxrLsqKREzmNYJACSWWpAWdNMwnD7c2BE= +google.golang.org/genproto v0.0.0-20230110181048-76db0878b65f/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= google.golang.org/genproto v0.0.0-20230127162408-596548ed4efa/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= +google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc h1:ijGwO+0vL2hJt5gaygqP2j6PfflOBrRot0IczKbmtio= +google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM= google.golang.org/grpc v1.12.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= google.golang.org/grpc v1.20.1/go.mod h1:10oTOabMzJvdu6/UiuZezV6QK5dSlG84ov/aaiqXj38= @@ -1405,8 +1455,9 @@ google.golang.org/grpc v1.49.0/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCD google.golang.org/grpc v1.50.0/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI= google.golang.org/grpc v1.50.1/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI= google.golang.org/grpc v1.51.0/go.mod h1:wgNDFcnuBGmxLKI/qn4T+m5BtEBYXJPvibbUPsAIPww= -google.golang.org/grpc v1.52.3 h1:pf7sOysg4LdgBqduXveGKrcEwbStiK2rtfghdzlUYDQ= google.golang.org/grpc v1.52.3/go.mod h1:pu6fVzoFb+NBYNAvQL08ic+lvB2IojljRYuun5vorUY= +google.golang.org/grpc v1.53.0 h1:LAv2ds7cmFV/XTS3XG1NneeENYrXGmorPxsBbptIjNc= +google.golang.org/grpc v1.53.0/go.mod h1:OnIrk0ipVdj4N5d9IUoFUx72/VlD7+jUsHwZgwSMQpw= google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw= google.golang.org/grpc/examples v0.0.0-20221201195934-736197138d20 h1:c4fmRt11lwyTYMMEA3IYCZR/xN7FEAJpwvPziaGXugs= google.golang.org/grpc/examples v0.0.0-20221201195934-736197138d20/go.mod h1:jMMKnsR3nPEOSsgT/Le2GxpknJOBOQms0nWb0JRgeUM= diff --git a/proto/api b/proto/api index 386b7cf9dcc..65015c07229 160000 --- a/proto/api +++ b/proto/api @@ -1 +1 @@ -Subproject commit 386b7cf9dccba864bdb38f28699f216a0f3fb2ca +Subproject commit 65015c07229047e82645923cc16285548e642794 diff --git a/proto/internal/temporal/server/api/historyservice/v1/request_response.proto b/proto/internal/temporal/server/api/historyservice/v1/request_response.proto index b64bc224c21..ed9db5b6f6c 100644 --- a/proto/internal/temporal/server/api/historyservice/v1/request_response.proto +++ b/proto/internal/temporal/server/api/historyservice/v1/request_response.proto @@ -58,6 +58,8 @@ message StartWorkflowExecutionRequest { int32 attempt = 4; google.protobuf.Timestamp workflow_execution_expiration_time = 5 [(gogoproto.stdtime) = true]; temporal.api.enums.v1.ContinueAsNewInitiator continue_as_new_initiator = 6; + // History service should use the values of continued_failure and last_completion_result + // here, not the ones in start_request (those are moved into here in the frontend). temporal.api.failure.v1.Failure continued_failure = 7; temporal.api.common.v1.Payloads last_completion_result = 8; google.protobuf.Duration first_workflow_task_backoff = 9 [(gogoproto.stdduration) = true]; diff --git a/proto/internal/temporal/server/api/schedule/v1/message.proto b/proto/internal/temporal/server/api/schedule/v1/message.proto index 641ae64e5dc..3a7347127da 100644 --- a/proto/internal/temporal/server/api/schedule/v1/message.proto +++ b/proto/internal/temporal/server/api/schedule/v1/message.proto @@ -101,9 +101,7 @@ message WatchWorkflowResponse { message StartWorkflowRequest { temporal.api.workflowservice.v1.StartWorkflowExecutionRequest request = 2; - reserved 3; - temporal.api.common.v1.Payloads last_completion_result = 4; - temporal.api.failure.v1.Failure continued_failure = 5; + reserved 3, 4, 5; bool completed_rate_limit_sleep = 6; } diff --git a/service/worker/scheduler/activities.go b/service/worker/scheduler/activities.go index 58530fad678..d6703ffbb59 100644 --- a/service/worker/scheduler/activities.go +++ b/service/worker/scheduler/activities.go @@ -92,16 +92,7 @@ func (a *activities) StartWorkflow(ctx context.Context, req *schedspb.StartWorkf req.Request.Namespace = a.namespace.String() - request := common.CreateHistoryStartWorkflowRequest( - a.namespaceID.String(), - req.Request, - nil, - time.Now().UTC(), - ) - request.LastCompletionResult = req.LastCompletionResult - request.ContinuedFailure = req.ContinuedFailure - - res, err := a.HistoryClient.StartWorkflowExecution(ctx, request) + res, err := a.FrontendClient.StartWorkflowExecution(ctx, req.Request) if err != nil { return nil, translateError(err, "StartWorkflowExecution") } diff --git a/service/worker/scheduler/workflow.go b/service/worker/scheduler/workflow.go index bd67dc7ad89..f1133f9dc15 100644 --- a/service/worker/scheduler/workflow.go +++ b/service/worker/scheduler/workflow.go @@ -840,9 +840,9 @@ func (s *scheduler) startWorkflow( Memo: newWorkflow.Memo, SearchAttributes: s.addSearchAttributes(newWorkflow.SearchAttributes, nominalTimeSec), Header: newWorkflow.Header, + LastCompletionResult: s.State.LastCompletionResult, + ContinuedFailure: s.State.ContinuedFailure, }, - LastCompletionResult: s.State.LastCompletionResult, - ContinuedFailure: s.State.ContinuedFailure, } for { var res schedspb.StartWorkflowResponse diff --git a/service/worker/scheduler/workflow_test.go b/service/worker/scheduler/workflow_test.go index 96b515561f8..6e9e48a8e4c 100644 --- a/service/worker/scheduler/workflow_test.go +++ b/service/worker/scheduler/workflow_test.go @@ -311,8 +311,8 @@ func (s *workflowSuite) TestStart() { s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.True(time.Date(2022, 6, 1, 0, 15, 0, 0, time.UTC).Equal(s.now())) - s.Nil(req.LastCompletionResult) - s.Nil(req.ContinuedFailure) + s.Nil(req.Request.LastCompletionResult) + s.Nil(req.Request.ContinuedFailure) s.Equal("myid-2022-06-01T00:15:00Z", req.Request.WorkflowId) s.Equal("mywf", req.Request.WorkflowType.Name) s.Equal("mytq", req.Request.TaskQueue.Name) @@ -843,8 +843,8 @@ func (s *workflowSuite) TestLastCompletionResultAndContinuedFailure() { s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.Equal("myid-2022-06-01T00:05:00Z", req.Request.WorkflowId) - s.Nil(req.LastCompletionResult) - s.Nil(req.ContinuedFailure) + s.Nil(req.Request.LastCompletionResult) + s.Nil(req.Request.ContinuedFailure) return nil, nil }) s.expectWatch(func(req *schedspb.WatchWorkflowRequest) (*schedspb.WatchWorkflowResponse, error) { @@ -859,8 +859,8 @@ func (s *workflowSuite) TestLastCompletionResultAndContinuedFailure() { }) s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.Equal("myid-2022-06-01T00:10:00Z", req.Request.WorkflowId) - s.Equal(`["res1"]`, payloads.ToString(req.LastCompletionResult)) - s.Nil(req.ContinuedFailure) + s.Equal(`["res1"]`, payloads.ToString(req.Request.LastCompletionResult)) + s.Nil(req.Request.ContinuedFailure) return nil, nil }) s.expectWatch(func(req *schedspb.WatchWorkflowRequest) (*schedspb.WatchWorkflowResponse, error) { @@ -875,8 +875,8 @@ func (s *workflowSuite) TestLastCompletionResultAndContinuedFailure() { }) s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.Equal("myid-2022-06-01T00:15:00Z", req.Request.WorkflowId) - s.Equal(`["res1"]`, payloads.ToString(req.LastCompletionResult)) - s.Equal(`oops`, req.ContinuedFailure.Message) + s.Equal(`["res1"]`, payloads.ToString(req.Request.LastCompletionResult)) + s.Equal(`oops`, req.Request.ContinuedFailure.Message) return nil, nil }) s.expectWatch(func(req *schedspb.WatchWorkflowRequest) (*schedspb.WatchWorkflowResponse, error) { @@ -891,8 +891,8 @@ func (s *workflowSuite) TestLastCompletionResultAndContinuedFailure() { }) s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.Equal("myid-2022-06-01T00:20:00Z", req.Request.WorkflowId) - s.Equal(`["works again"]`, payloads.ToString(req.LastCompletionResult)) - s.Nil(req.ContinuedFailure) + s.Equal(`["works again"]`, payloads.ToString(req.Request.LastCompletionResult)) + s.Nil(req.Request.ContinuedFailure) return nil, nil }) @@ -916,8 +916,8 @@ func (s *workflowSuite) TestPauseOnFailure() { s.expectStart(func(req *schedspb.StartWorkflowRequest) (*schedspb.StartWorkflowResponse, error) { s.True(time.Date(2022, 6, 1, 0, 5, 0, 0, time.UTC).Equal(s.now())) s.Equal("myid-2022-06-01T00:05:00Z", req.Request.WorkflowId) - s.Nil(req.LastCompletionResult) - s.Nil(req.ContinuedFailure) + s.Nil(req.Request.LastCompletionResult) + s.Nil(req.Request.ContinuedFailure) return nil, nil }) s.expectWatch(func(req *schedspb.WatchWorkflowRequest) (*schedspb.WatchWorkflowResponse, error) { diff --git a/tests/schedule_test.go b/tests/schedule_test.go index 2309bffd72b..e344dac9f5f 100644 --- a/tests/schedule_test.go +++ b/tests/schedule_test.go @@ -25,6 +25,7 @@ package tests import ( + "errors" "flag" "fmt" "strings" @@ -63,8 +64,6 @@ various validation errors overlap policies, esp. buffer -last completion result and last error - worker restart/long-poll activity failure: get it in a state where it's waiting for a wf to exit, say with bufferone restart the worker/force activity to fail @@ -477,6 +476,85 @@ func (s *scheduleIntegrationSuite) TestInput() { s.NoError(err) } +func (s *scheduleIntegrationSuite) TestLastCompletionAndError() { + sid := "sched-test-last" + wid := "sched-test-last-wf" + wt := "sched-test-last-wt" + + schedule := &schedulepb.Schedule{ + Spec: &schedulepb.ScheduleSpec{ + Interval: []*schedulepb.IntervalSpec{ + {Interval: timestamp.DurationPtr(3 * time.Second)}, + }, + }, + Action: &schedulepb.ScheduleAction{ + Action: &schedulepb.ScheduleAction_StartWorkflow{ + StartWorkflow: &workflowpb.NewWorkflowExecutionInfo{ + WorkflowId: wid, + WorkflowType: &commonpb.WorkflowType{Name: wt}, + TaskQueue: &taskqueuepb.TaskQueue{Name: s.taskQueue}, + }, + }, + }, + } + req := &workflowservice.CreateScheduleRequest{ + Namespace: s.namespace, + ScheduleId: sid, + Schedule: schedule, + Identity: "test", + RequestId: uuid.New(), + } + + runs := make(map[string]struct{}) + var testComplete int32 + + workflowFn := func(ctx workflow.Context) (string, error) { + var num int + _ = workflow.SideEffect(ctx, func(ctx workflow.Context) any { + runs[workflow.GetInfo(ctx).WorkflowExecution.ID] = struct{}{} + return len(runs) + }).Get(&num) + + var lcr string + if workflow.HasLastCompletionResult(ctx) { + s.NoError(workflow.GetLastCompletionResult(ctx, &lcr)) + } + + lastErr := workflow.GetLastError(ctx) + + switch num { + case 1: + s.Equal("", lcr) + s.NoError(lastErr) + return "this one succeeds", nil + case 2: + s.NoError(lastErr) + s.Equal("this one succeeds", lcr) + return "", errors.New("this one fails") + case 3: + s.Equal("this one succeeds", lcr) + s.ErrorContains(lastErr, "this one fails") + atomic.StoreInt32(&testComplete, 1) + return "done", nil + default: + panic("shouldn't be running anymore") + } + } + s.worker.RegisterWorkflowWithOptions(workflowFn, workflow.RegisterOptions{Name: wt}) + + _, err := s.engine.CreateSchedule(NewContext(), req) + s.NoError(err) + s.Eventually(func() bool { return atomic.LoadInt32(&testComplete) == 1 }, 15*time.Second, 200*time.Millisecond) + + // cleanup + _, err = s.engine.DeleteSchedule(NewContext(), &workflowservice.DeleteScheduleRequest{ + Namespace: s.namespace, + ScheduleId: sid, + Identity: "test", + }) + s.NoError(err) +} + func (s *scheduleIntegrationSuite) TestRefresh() { sid := "sched-test-refresh" wid := "sched-test-refresh-wf"