Update idls (uber#5813)

aditigautam78 · Mar 25, 2024 · 27234b9 · 27234b9
1 parent 07644ce
commit 27234b9
Show file tree

Hide file tree

Showing 13 changed files with 1,023 additions and 713 deletions.
diff --git a/.gen/go/shared/shared.go b/.gen/go/shared/shared.go
diff --git a/.gen/proto/history/v1/service.pb.yarpc.go b/.gen/proto/history/v1/service.pb.yarpc.go
diff --git a/.gen/proto/matching/v1/service.pb.yarpc.go b/.gen/proto/matching/v1/service.pb.yarpc.go
diff --git a/.gen/proto/shared/v1/history.pb.yarpc.go b/.gen/proto/shared/v1/history.pb.yarpc.go
diff --git a/cmd/server/go.mod b/cmd/server/go.mod
@@ -43,7 +43,7 @@ require (
 	github.com/startreedata/pinot-client-go v0.2.0 // latest release supports pinot v0.12.0 which is also internal version
 	github.com/stretchr/testify v1.8.3
 	github.com/uber-go/tally v3.3.15+incompatible // indirect
-	github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210
+	github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562
 	github.com/uber/ringpop-go v0.8.5 // indirect
 	github.com/uber/tchannel-go v1.22.2 // indirect
 	github.com/urfave/cli v1.22.4

diff --git a/cmd/server/go.sum b/cmd/server/go.sum
@@ -397,8 +397,8 @@ github.com/uber-go/tally v3.3.12+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyu
 github.com/uber-go/tally v3.3.15+incompatible h1:9hLSgNBP28CjIaDmAuRTq9qV+UZY+9PcvAkXO4nNMwg=
 github.com/uber-go/tally v3.3.15+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyufu1cEi0jdVnRdxvjnmU=
 github.com/uber/cadence-idl v0.0.0-20211111101836-d6b70b60eb8c/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
-github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210 h1:iuPF2QAZM90Jpx0s+2LnxLN+ElGsxB2JnXKGNLc18+w=
-github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
+github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562 h1:/G/9GZPDEfZOgKIwjIIuEtFqLh4i4RDySpVvcx6jERY=
+github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
 github.com/uber/jaeger-client-go v2.22.1+incompatible h1:NHcubEkVbahf9t3p75TOCR83gdUHXjRJvjoBh1yACsM=
 github.com/uber/jaeger-client-go v2.22.1+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
 github.com/uber/jaeger-lib v2.2.0+incompatible h1:MxZXOiR2JuoANZ3J6DE/U0kSFv/eJ/GfSYVCjK7dyaw=

diff --git a/common/types/mapper/proto/api.go b/common/types/mapper/proto/api.go
@@ -911,6 +911,7 @@ func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttri
 		NewRunId:         t.NewRunID,
 		ForkEventVersion: t.ForkEventVersion,
 		BinaryChecksum:   t.BinaryChecksum,
+		RequestId:        t.RequestID,
 	}
 }
 
@@ -929,6 +930,7 @@ func ToDecisionTaskFailedEventAttributes(t *apiv1.DecisionTaskFailedEventAttribu
 		NewRunID:         t.NewRunId,
 		ForkEventVersion: t.ForkEventVersion,
 		BinaryChecksum:   t.BinaryChecksum,
+		RequestID:        t.RequestId,
 	}
 }
 
@@ -4472,6 +4474,7 @@ func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecut
 		Cause:                 t.Cause,
 		ExternalExecutionInfo: FromExternalExecutionInfoFields(t.ExternalWorkflowExecution, t.ExternalInitiatedEventID),
 		Identity:              t.Identity,
+		RequestId:             t.RequestID,
 	}
 }
 
@@ -4484,6 +4487,7 @@ func ToWorkflowExecutionCancelRequestedEventAttributes(t *apiv1.WorkflowExecutio
 		ExternalInitiatedEventID:  ToExternalInitiatedID(t.ExternalExecutionInfo),
 		ExternalWorkflowExecution: ToExternalWorkflowExecution(t.ExternalExecutionInfo),
 		Identity:                  t.Identity,
+		RequestID:                 t.RequestId,
 	}
 }
 
@@ -4801,6 +4805,7 @@ func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSign
 		SignalName: t.SignalName,
 		Input:      FromPayload(t.Input),
 		Identity:   t.Identity,
+		RequestId:  t.RequestID,
 	}
 }
 
@@ -4812,6 +4817,7 @@ func ToWorkflowExecutionSignaledEventAttributes(t *apiv1.WorkflowExecutionSignal
 		SignalName: t.SignalName,
 		Input:      ToPayload(t.Input),
 		Identity:   t.Identity,
+		RequestID:  t.RequestId,
 	}
 }
 
@@ -4845,6 +4851,7 @@ func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStart
 		PrevAutoResetPoints:          FromResetPoints(t.PrevAutoResetPoints),
 		Header:                       FromHeader(t.Header),
 		PartitionConfig:              t.PartitionConfig,
+		RequestId:                    t.RequestID,
 	}
 }
 
@@ -4881,6 +4888,7 @@ func ToWorkflowExecutionStartedEventAttributes(t *apiv1.WorkflowExecutionStarted
 		PrevAutoResetPoints:                 ToResetPoints(t.PrevAutoResetPoints),
 		Header:                              ToHeader(t.Header),
 		PartitionConfig:                     t.PartitionConfig,
+		RequestID:                           t.RequestId,
 	}
 }
 

diff --git a/common/types/mapper/thrift/shared.go b/common/types/mapper/thrift/shared.go
@@ -1268,6 +1268,7 @@ func FromDecisionTaskFailedEventAttributes(t *types.DecisionTaskFailedEventAttri
 		NewRunId:         &t.NewRunID,
 		ForkEventVersion: &t.ForkEventVersion,
 		BinaryChecksum:   &t.BinaryChecksum,
+		RequestId:        &t.RequestID,
 	}
 }
 
@@ -1287,6 +1288,7 @@ func ToDecisionTaskFailedEventAttributes(t *shared.DecisionTaskFailedEventAttrib
 		NewRunID:         t.GetNewRunId(),
 		ForkEventVersion: t.GetForkEventVersion(),
 		BinaryChecksum:   t.GetBinaryChecksum(),
+		RequestID:        t.GetRequestId(),
 	}
 }
 
@@ -6100,6 +6102,7 @@ func FromWorkflowExecutionCancelRequestedEventAttributes(t *types.WorkflowExecut
 		ExternalInitiatedEventId:  t.ExternalInitiatedEventID,
 		ExternalWorkflowExecution: FromWorkflowExecution(t.ExternalWorkflowExecution),
 		Identity:                  &t.Identity,
+		RequestId:                 &t.RequestID,
 	}
 }
 
@@ -6113,6 +6116,7 @@ func ToWorkflowExecutionCancelRequestedEventAttributes(t *shared.WorkflowExecuti
 		ExternalInitiatedEventID:  t.ExternalInitiatedEventId,
 		ExternalWorkflowExecution: ToWorkflowExecution(t.ExternalWorkflowExecution),
 		Identity:                  t.GetIdentity(),
+		RequestID:                 t.GetRequestId(),
 	}
 }
 
@@ -6397,6 +6401,7 @@ func FromWorkflowExecutionSignaledEventAttributes(t *types.WorkflowExecutionSign
 		SignalName: &t.SignalName,
 		Input:      t.Input,
 		Identity:   &t.Identity,
+		RequestId:  &t.RequestID,
 	}
 }
 
@@ -6409,6 +6414,7 @@ func ToWorkflowExecutionSignaledEventAttributes(t *shared.WorkflowExecutionSigna
 		SignalName: t.GetSignalName(),
 		Input:      t.Input,
 		Identity:   t.GetIdentity(),
+		RequestID:  t.GetRequestId(),
 	}
 }
 
@@ -6446,6 +6452,7 @@ func FromWorkflowExecutionStartedEventAttributes(t *types.WorkflowExecutionStart
 		PrevAutoResetPoints:                 FromResetPoints(t.PrevAutoResetPoints),
 		Header:                              FromHeader(t.Header),
 		PartitionConfig:                     t.PartitionConfig,
+		RequestId:                           &t.RequestID,
 	}
 }
 
@@ -6483,6 +6490,7 @@ func ToWorkflowExecutionStartedEventAttributes(t *shared.WorkflowExecutionStarte
 		PrevAutoResetPoints:                 ToResetPoints(t.PrevAutoResetPoints),
 		Header:                              ToHeader(t.Header),
 		PartitionConfig:                     t.PartitionConfig,
+		RequestID:                           t.GetRequestId(),
 	}
 }
 

diff --git a/common/types/shared.go b/common/types/shared.go
@@ -1146,6 +1146,7 @@ type DecisionTaskFailedEventAttributes struct {
 	NewRunID         string                   `json:"newRunId,omitempty"`
 	ForkEventVersion int64                    `json:"forkEventVersion,omitempty"`
 	BinaryChecksum   string                   `json:"binaryChecksum,omitempty"`
+	RequestID        string                   `json:"requestId,omitempty"`
 }
 
 // GetCause is an internal getter (TBD...)
@@ -1188,6 +1189,14 @@ func (v *DecisionTaskFailedEventAttributes) GetForkEventVersion() (o int64) {
 	return
 }
 
+// GetRequestID is an internal getter (TBD...)
+func (v *DecisionTaskFailedEventAttributes) GetRequestID() (o string) {
+	if v != nil {
+		return v.RequestID
+	}
+	return
+}
+
 // DecisionTaskScheduledEventAttributes is an internal type (TBD...)
 type DecisionTaskScheduledEventAttributes struct {
 	TaskList                   *TaskList `json:"taskList,omitempty"`
@@ -7041,6 +7050,7 @@ type WorkflowExecutionCancelRequestedEventAttributes struct {
 	ExternalInitiatedEventID  *int64             `json:"externalInitiatedEventId,omitempty"`
 	ExternalWorkflowExecution *WorkflowExecution `json:"externalWorkflowExecution,omitempty"`
 	Identity                  string             `json:"identity,omitempty"`
+	RequestID                 string             `json:"requestId,omitempty"`
 }
 
 // WorkflowExecutionCanceledEventAttributes is an internal type (TBD...)
@@ -7321,6 +7331,7 @@ type WorkflowExecutionSignaledEventAttributes struct {
 	SignalName string `json:"signalName,omitempty"`
 	Input      []byte `json:"input,omitempty"`
 	Identity   string `json:"identity,omitempty"`
+	RequestID  string `json:"requestId,omitempty"`
 }
 
 // GetSignalName is an internal getter (TBD...)
@@ -7347,6 +7358,14 @@ func (v *WorkflowExecutionSignaledEventAttributes) GetIdentity() (o string) {
 	return
 }
 
+// GetRequestID is an internal getter (TBD...)
+func (v *WorkflowExecutionSignaledEventAttributes) GetRequestID() (o string) {
+	if v != nil {
+		return v.RequestID
+	}
+	return
+}
+
 // WorkflowExecutionStartedEventAttributes is an internal type (TBD...)
 type WorkflowExecutionStartedEventAttributes struct {
 	WorkflowType                        *WorkflowType           `json:"workflowType,omitempty"`
@@ -7378,6 +7397,7 @@ type WorkflowExecutionStartedEventAttributes struct {
 	Header                              *Header                 `json:"header,omitempty"`
 	JitterStartSeconds                  *int32                  `json:"jitterStartSeconds,omitempty"`
 	PartitionConfig                     map[string]string
+	RequestID                           string `json:"requestId,omitempty"`
 }
 
 // GetParentWorkflowDomain is an internal getter (TBD...)
@@ -7515,6 +7535,14 @@ func (v *WorkflowExecutionStartedEventAttributes) GetPartitionConfig() (o map[st
 	return
 }
 
+// GetRequestID is an internal getter (TBD...)
+func (v *WorkflowExecutionStartedEventAttributes) GetRequestID() (o string) {
+	if v != nil {
+		return v.RequestID
+	}
+	return
+}
+
 // WorkflowExecutionTerminatedEventAttributes is an internal type (TBD...)
 type WorkflowExecutionTerminatedEventAttributes struct {
 	Reason   string `json:"reason,omitempty"`

diff --git a/common/types/testdata/history.go b/common/types/testdata/history.go
@@ -274,6 +274,7 @@ var (
 		PrevAutoResetPoints:                 &ResetPoints,
 		Header:                              &Header,
 		PartitionConfig:                     PartitionConfig,
+		RequestID:                           RequestID,
 	}
 	WorkflowExecutionCompletedEventAttributes = types.WorkflowExecutionCompletedEventAttributes{
 		Result:                       Payload1,
@@ -325,6 +326,7 @@ var (
 		NewRunID:         RunID2,
 		ForkEventVersion: Version1,
 		BinaryChecksum:   Checksum,
+		RequestID:        RequestID,
 	}
 	ActivityTaskScheduledEventAttributes = types.ActivityTaskScheduledEventAttributes{
 		ActivityID:                    ActivityID,
@@ -416,6 +418,7 @@ var (
 		SignalName: SignalName,
 		Input:      Payload1,
 		Identity:   Identity,
+		RequestID:  RequestID,
 	}
 	WorkflowExecutionTerminatedEventAttributes = types.WorkflowExecutionTerminatedEventAttributes{
 		Reason:   Reason,
@@ -427,6 +430,7 @@ var (
 		ExternalInitiatedEventID:  common.Int64Ptr(EventID1),
 		ExternalWorkflowExecution: &WorkflowExecution,
 		Identity:                  Identity,
+		RequestID:                 RequestID,
 	}
 	WorkflowExecutionCanceledEventAttributes = types.WorkflowExecutionCanceledEventAttributes{
 		DecisionTaskCompletedEventID: EventID1,

diff --git a/go.mod b/go.mod
@@ -40,7 +40,7 @@ require (
 	github.com/startreedata/pinot-client-go v0.2.0 // latest release supports pinot v0.12.0 which is also internal version
 	github.com/stretchr/testify v1.8.3
 	github.com/uber-go/tally v3.3.15+incompatible
-	github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210
+	github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562
 	github.com/uber/ringpop-go v0.8.5
 	github.com/uber/tchannel-go v1.22.2
 	github.com/urfave/cli v1.22.4

diff --git a/go.sum b/go.sum
@@ -444,8 +444,8 @@ github.com/uber-go/tally v3.3.12+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyu
 github.com/uber-go/tally v3.3.15+incompatible h1:9hLSgNBP28CjIaDmAuRTq9qV+UZY+9PcvAkXO4nNMwg=
 github.com/uber-go/tally v3.3.15+incompatible/go.mod h1:YDTIBxdXyOU/sCWilKB4bgyufu1cEi0jdVnRdxvjnmU=
 github.com/uber/cadence-idl v0.0.0-20211111101836-d6b70b60eb8c/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
-github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210 h1:iuPF2QAZM90Jpx0s+2LnxLN+ElGsxB2JnXKGNLc18+w=
-github.com/uber/cadence-idl v0.0.0-20240318101217-afd574441210/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
+github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562 h1:/G/9GZPDEfZOgKIwjIIuEtFqLh4i4RDySpVvcx6jERY=
+github.com/uber/cadence-idl v0.0.0-20240323004316-cd945be66562/go.mod h1:oyUK7GCNCRHCCyWyzifSzXpVrRYVBbAMHAzF5dXiKws=
 github.com/uber/jaeger-client-go v2.22.1+incompatible h1:NHcubEkVbahf9t3p75TOCR83gdUHXjRJvjoBh1yACsM=
 github.com/uber/jaeger-client-go v2.22.1+incompatible/go.mod h1:WVhlPFC8FDjOFMMWRy2pZqQJSXxYSwNYOkTr/Z6d3Kk=
 github.com/uber/jaeger-lib v2.2.0+incompatible h1:MxZXOiR2JuoANZ3J6DE/U0kSFv/eJ/GfSYVCjK7dyaw=

diff --git a/idls b/idls