diff --git a/api/persistence/v1/executions.pb.go b/api/persistence/v1/executions.pb.go index d565bd2f97b..e91ae873c51 100644 --- a/api/persistence/v1/executions.pb.go +++ b/api/persistence/v1/executions.pb.go @@ -348,7 +348,7 @@ type WorkflowExecutionInfo struct { PreviousTransitionHistory []*VersionedTransition `protobuf:"bytes,100,rep,name=previous_transition_history,json=previousTransitionHistory,proto3" json:"previous_transition_history,omitempty"` LastTransitionHistoryBreakPoint *VersionedTransition `protobuf:"bytes,101,opt,name=last_transition_history_break_point,json=lastTransitionHistoryBreakPoint,proto3" json:"last_transition_history_break_point,omitempty"` // This is a set of child workflows that were initialized after the reset point in the parent workflow. - // The children are identified by the key "workflow_id:workflow_type". When the parent starts to make progress after reset, it uses this data to + // The children are identified by the key "workflow_type:workflow_id". When the parent starts to make progress after reset, it uses this data to // determine the right start policy to apply to the child. ChildrenInitializedPostResetPoint map[string]bool `protobuf:"bytes,102,rep,name=children_initialized_post_reset_point,json=childrenInitializedPostResetPoint,proto3" json:"children_initialized_post_reset_point,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` } diff --git a/proto/internal/temporal/server/api/persistence/v1/executions.proto b/proto/internal/temporal/server/api/persistence/v1/executions.proto index a64b8e24663..576e25bc50c 100644 --- a/proto/internal/temporal/server/api/persistence/v1/executions.proto +++ b/proto/internal/temporal/server/api/persistence/v1/executions.proto @@ -282,7 +282,7 @@ message WorkflowExecutionInfo { VersionedTransition last_transition_history_break_point = 101; // This is a set of child workflows that were initialized after the reset point in the parent workflow. - // The children are identified by the key "workflow_id:workflow_type". When the parent starts to make progress after reset, it uses this data to + // The children are identified by the key "workflow_type:workflow_id". When the parent starts to make progress after reset, it uses this data to // determine the right start policy to apply to the child. map children_initialized_post_reset_point = 102; } diff --git a/service/history/workflow/mutable_state.go b/service/history/workflow/mutable_state.go index d35afae6259..daa9f4c8a9b 100644 --- a/service/history/workflow/mutable_state.go +++ b/service/history/workflow/mutable_state.go @@ -240,6 +240,8 @@ type ( UpdateResetRunID(runID string) // IsResetRun returns true if this run is result of a reset operation. IsResetRun() bool + SetChildrenInitializedPostResetPoint(children map[string]bool) + GetChildrenInitializedPostResetPoint() map[string]bool CloneToProto() *persistencespb.WorkflowMutableState RetryActivity(ai *persistencespb.ActivityInfo, failure *failurepb.Failure) (enumspb.RetryState, error) diff --git a/service/history/workflow/mutable_state_mock.go b/service/history/workflow/mutable_state_mock.go index 83e600bdb95..bba57dea8d7 100644 --- a/service/history/workflow/mutable_state_mock.go +++ b/service/history/workflow/mutable_state_mock.go @@ -1905,6 +1905,20 @@ func (mr *MockMutableStateMockRecorder) GetChildExecutionInitiatedEvent(arg0, ar return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChildExecutionInitiatedEvent", reflect.TypeOf((*MockMutableState)(nil).GetChildExecutionInitiatedEvent), arg0, arg1) } +// GetChildrenInitializedPostResetPoint mocks base method. +func (m *MockMutableState) GetChildrenInitializedPostResetPoint() map[string]bool { + m.ctrl.T.Helper() + ret := m.ctrl.Call(m, "GetChildrenInitializedPostResetPoint") + ret0, _ := ret[0].(map[string]bool) + return ret0 +} + +// GetChildrenInitializedPostResetPoint indicates an expected call of GetChildrenInitializedPostResetPoint. +func (mr *MockMutableStateMockRecorder) GetChildrenInitializedPostResetPoint() *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChildrenInitializedPostResetPoint", reflect.TypeOf((*MockMutableState)(nil).GetChildrenInitializedPostResetPoint)) +} + // GetCloseVersion mocks base method. func (m *MockMutableState) GetCloseVersion() (int64, error) { m.ctrl.T.Helper() @@ -3026,6 +3040,18 @@ func (mr *MockMutableStateMockRecorder) SetBaseWorkflow(baseRunID, baseRunLowest return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetBaseWorkflow", reflect.TypeOf((*MockMutableState)(nil).SetBaseWorkflow), baseRunID, baseRunLowestCommonAncestorEventID, baseRunLowestCommonAncestorEventVersion) } +// SetChildrenInitializedPostResetPoint mocks base method. +func (m *MockMutableState) SetChildrenInitializedPostResetPoint(children map[string]bool) { + m.ctrl.T.Helper() + m.ctrl.Call(m, "SetChildrenInitializedPostResetPoint", children) +} + +// SetChildrenInitializedPostResetPoint indicates an expected call of SetChildrenInitializedPostResetPoint. +func (mr *MockMutableStateMockRecorder) SetChildrenInitializedPostResetPoint(children any) *gomock.Call { + mr.mock.ctrl.T.Helper() + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetChildrenInitializedPostResetPoint", reflect.TypeOf((*MockMutableState)(nil).SetChildrenInitializedPostResetPoint), children) +} + // SetCurrentBranchToken mocks base method. func (m *MockMutableState) SetCurrentBranchToken(branchToken []byte) error { m.ctrl.T.Helper()