Add FirstExecutionRunID to mutable state (uber#5031)

gaoskye · Nov 23, 2022 · d249434 · d249434
1 parent 1a52714
commit d249434
Show file tree

Hide file tree

Showing 26 changed files with 587 additions and 304 deletions.
diff --git a/.gen/go/shared/shared.go b/.gen/go/shared/shared.go
diff --git a/.gen/go/sqlblobs/sqlblobs.go b/.gen/go/sqlblobs/sqlblobs.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/common/persistence/dataManagerInterfaces.go b/common/persistence/dataManagerInterfaces.go
@@ -302,6 +302,7 @@ type (
 		DomainID                           string
 		WorkflowID                         string
 		RunID                              string
+		FirstExecutionRunID                string
 		ParentDomainID                     string
 		ParentWorkflowID                   string
 		ParentRunID                        string

diff --git a/common/persistence/dataStoreInterfaces.go b/common/persistence/dataStoreInterfaces.go
@@ -273,6 +273,7 @@ type (
 		DomainID                           string
 		WorkflowID                         string
 		RunID                              string
+		FirstExecutionRunID                string
 		ParentDomainID                     string
 		ParentWorkflowID                   string
 		ParentRunID                        string

diff --git a/common/persistence/executionManager.go b/common/persistence/executionManager.go
@@ -135,6 +135,7 @@ func (m *executionManagerImpl) DeserializeExecutionInfo(
 		DomainID:                           info.DomainID,
 		WorkflowID:                         info.WorkflowID,
 		RunID:                              info.RunID,
+		FirstExecutionRunID:                info.FirstExecutionRunID,
 		ParentDomainID:                     info.ParentDomainID,
 		ParentWorkflowID:                   info.ParentWorkflowID,
 		ParentRunID:                        info.ParentRunID,
@@ -459,6 +460,7 @@ func (m *executionManagerImpl) SerializeExecutionInfo(
 		DomainID:                           info.DomainID,
 		WorkflowID:                         info.WorkflowID,
 		RunID:                              info.RunID,
+		FirstExecutionRunID:                info.FirstExecutionRunID,
 		ParentDomainID:                     info.ParentDomainID,
 		ParentWorkflowID:                   info.ParentWorkflowID,
 		ParentRunID:                        info.ParentRunID,

diff --git a/common/persistence/nosql/nosqlExecutionStoreUtil.go b/common/persistence/nosql/nosqlExecutionStoreUtil.go
@@ -622,6 +622,11 @@ func (d *nosqlExecutionStore) prepareUpdateWorkflowExecutionTxn(
 		executionInfo.InitiatedID = emptyInitiatedID
 	}
 
+	// TODO: remove this logic once all workflows before 0.26.x are completed
+	if executionInfo.FirstExecutionRunID == "" {
+		executionInfo.FirstExecutionRunID = emptyRunID
+	}
+
 	executionInfo.CompletionEvent = executionInfo.CompletionEvent.ToNilSafeDataBlob()
 	executionInfo.AutoResetPoints = executionInfo.AutoResetPoints.ToNilSafeDataBlob()
 	// TODO also need to set the start / current / last write version
@@ -655,6 +660,11 @@ func (d *nosqlExecutionStore) prepareCreateWorkflowExecutionTxn(
 		executionInfo.InitiatedID = emptyInitiatedID
 	}
 
+	// TODO: remove this logic once all workflows before 0.26.x are completed
+	if executionInfo.FirstExecutionRunID == "" {
+		executionInfo.FirstExecutionRunID = emptyRunID
+	}
+
 	if executionInfo.StartTimestamp.IsZero() {
 		executionInfo.StartTimestamp = nowTimestamp
 		d.logger.Error("Workflow startTimestamp not set, fallback to now",

diff --git a/common/persistence/nosql/nosqlplugin/cassandra/workflowCql.go b/common/persistence/nosql/nosqlplugin/cassandra/workflowCql.go
@@ -26,6 +26,7 @@ const (
 		`domain_id: ?, ` +
 		`workflow_id: ?, ` +
 		`run_id: ?, ` +
+		`first_run_id: ?, ` +
 		`parent_domain_id: ?, ` +
 		`parent_workflow_id: ?, ` +
 		`parent_run_id: ?, ` +

diff --git a/common/persistence/nosql/nosqlplugin/cassandra/workflowParsingUtils.go b/common/persistence/nosql/nosqlplugin/cassandra/workflowParsingUtils.go
@@ -54,6 +54,14 @@ func parseWorkflowExecutionInfo(
 			info.WorkflowID = v.(string)
 		case "run_id":
 			info.RunID = v.(gocql.UUID).String()
+		case "first_run_id":
+			info.FirstExecutionRunID = v.(gocql.UUID).String()
+			if info.FirstExecutionRunID == _emptyUUID.String() {
+				// for backward compatibility, the gocql library doesn't handle the null uuid correectly https://github.com/gocql/gocql/blob/master/marshal.go#L1807
+				info.FirstExecutionRunID = ""
+			} else if info.FirstExecutionRunID == emptyRunID {
+				info.FirstExecutionRunID = ""
+			}
 		case "parent_domain_id":
 			info.ParentDomainID = v.(gocql.UUID).String()
 			if info.ParentDomainID == emptyDomainID {

diff --git a/common/persistence/nosql/nosqlplugin/cassandra/workflowUtils.go b/common/persistence/nosql/nosqlplugin/cassandra/workflowUtils.go
@@ -1210,6 +1210,7 @@ func (db *cdb) updateWorkflowExecution(
 		domainID,
 		workflowID,
 		execution.RunID,
+		execution.FirstExecutionRunID,
 		execution.ParentDomainID,
 		execution.ParentWorkflowID,
 		execution.ParentRunID,
@@ -1304,6 +1305,7 @@ func (db *cdb) createWorkflowExecution(
 		domainID,
 		workflowID,
 		execution.RunID,
+		execution.FirstExecutionRunID,
 		execution.ParentDomainID,
 		execution.ParentWorkflowID,
 		execution.ParentRunID,

diff --git a/common/persistence/persistence-tests/executionManagerTest.go b/common/persistence/persistence-tests/executionManagerTest.go
@@ -135,6 +135,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionDeDup() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowID,
 				RunID:                       runID,
+				FirstExecutionRunID:         runID,
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -239,6 +240,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus() {
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionStatusCreated.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionStatusCreated.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionStatusCreated.GetRunID()
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateCreated
 	for _, invalidCloseStatus := range invalidCloseStatuses {
 		req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = invalidCloseStatus
@@ -260,6 +262,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus() {
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionStatusRunning.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionStatusRunning.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionStatusRunning.GetRunID()
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateRunning
 	for _, invalidCloseStatus := range invalidCloseStatuses {
 		req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = invalidCloseStatus
@@ -281,6 +284,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus() {
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionStatusCompleted.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionStatusCompleted.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionStatusCompleted.GetRunID()
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateCompleted
 	for _, invalidCloseStatus := range invalidCloseStatuses {
 		req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = invalidCloseStatus
@@ -300,6 +304,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionStateCloseStatus() {
 	req.Mode = p.CreateWorkflowModeZombie
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionStatusZombie.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionStatusZombie.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionStatusZombie.GetRunID()
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateZombie
 	for _, invalidCloseStatus := range invalidCloseStatuses {
 		req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = invalidCloseStatus
@@ -349,6 +354,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionWithZombieState() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowID,
 				RunID:                       workflowExecutionZombie1.GetRunID(),
+				FirstExecutionRunID:         workflowExecutionZombie1.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -375,6 +381,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionWithZombieState() {
 		RunID:      uuid.New(),
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionRunning.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionRunning.GetRunID()
 	req.Mode = p.CreateWorkflowModeBrandNew
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateRunning
 	req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = p.WorkflowCloseStatusNone
@@ -389,6 +396,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionWithZombieState() {
 		RunID:      uuid.New(),
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionZombie.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionZombie.GetRunID()
 	req.Mode = p.CreateWorkflowModeZombie
 	req.NewWorkflowSnapshot.ExecutionInfo.State = p.WorkflowStateZombie
 	req.NewWorkflowSnapshot.ExecutionInfo.CloseStatus = p.WorkflowCloseStatusNone
@@ -445,6 +453,7 @@ func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionStateCloseStatus() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -553,6 +562,7 @@ func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionStateCloseStatus() {
 	}
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionRunning.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionRunning.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionRunning.GetRunID()
 	req.Mode = p.CreateWorkflowModeWorkflowIDReuse
 	req.PreviousRunID = workflowExecution.GetRunID()
 	req.PreviousLastWriteVersion = common.EmptyVersion
@@ -633,6 +643,7 @@ func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionWithZombieState() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -700,6 +711,7 @@ func (s *ExecutionManagerSuite) TestUpdateWorkflowExecutionWithZombieState() {
 	csum = checksum.Checksum{} // set checksum to nil
 	req.NewWorkflowSnapshot.ExecutionInfo.WorkflowID = workflowExecutionRunning.GetWorkflowID()
 	req.NewWorkflowSnapshot.ExecutionInfo.RunID = workflowExecutionRunning.GetRunID()
+	req.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = workflowExecutionRunning.GetRunID()
 	req.Mode = p.CreateWorkflowModeWorkflowIDReuse
 	req.PreviousRunID = workflowExecution.GetRunID()
 	req.PreviousLastWriteVersion = common.EmptyVersion
@@ -856,6 +868,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionBrandNew() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -919,6 +932,7 @@ func (s *ExecutionManagerSuite) TestUpsertWorkflowActivity() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -1058,6 +1072,7 @@ func (s *ExecutionManagerSuite) TestCreateWorkflowExecutionRunIDReuseWithoutRepl
 				DomainID:                    domainID,
 				WorkflowID:                  newExecution.GetWorkflowID(),
 				RunID:                       newExecution.GetRunID(),
+				FirstExecutionRunID:         newExecution.GetRunID(),
 				TaskList:                    tasklist,
 				WorkflowTypeName:            workflowType,
 				WorkflowTimeout:             workflowTimeout,
@@ -1181,6 +1196,7 @@ func (s *ExecutionManagerSuite) TestPersistenceStartWorkflow() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    "queue1",
 				WorkflowTypeName:            "workflow_type_test",
 				WorkflowTimeout:             20,
@@ -1305,6 +1321,7 @@ func (s *ExecutionManagerSuite) TestGetWorkflow() {
 		},
 		Mode: p.CreateWorkflowModeBrandNew,
 	}
+	createReq.NewWorkflowSnapshot.ExecutionInfo.FirstExecutionRunID = createReq.NewWorkflowSnapshot.ExecutionInfo.RunID
 
 	createResp, err := s.ExecutionManager.CreateWorkflowExecution(ctx, createReq)
 	s.NoError(err)
@@ -4412,6 +4429,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -4583,6 +4601,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -4734,6 +4753,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -4853,6 +4873,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -5011,6 +5032,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -5153,6 +5175,7 @@ func (s *ExecutionManagerSuite) TestConflictResolveWorkflowExecutionWithTransact
 		DomainID:                    domainID,
 		WorkflowID:                  workflowExecutionReset.GetWorkflowID(),
 		RunID:                       workflowExecutionReset.GetRunID(),
+		FirstExecutionRunID:         workflowExecutionReset.GetRunID(),
 		ParentDomainID:              uuid.New(),
 		ParentWorkflowID:            "some random parent workflow ID",
 		ParentRunID:                 uuid.New(),
@@ -5328,6 +5351,7 @@ func copyWorkflowExecutionInfo(sourceInfo *p.WorkflowExecutionInfo) *p.WorkflowE
 		DomainID:                    sourceInfo.DomainID,
 		WorkflowID:                  sourceInfo.WorkflowID,
 		RunID:                       sourceInfo.RunID,
+		FirstExecutionRunID:         sourceInfo.FirstExecutionRunID,
 		ParentDomainID:              sourceInfo.ParentDomainID,
 		ParentWorkflowID:            sourceInfo.ParentWorkflowID,
 		ParentRunID:                 sourceInfo.ParentRunID,

diff --git a/common/persistence/persistence-tests/executionManagerTestForEventsV2.go b/common/persistence/persistence-tests/executionManagerTestForEventsV2.go
@@ -121,6 +121,7 @@ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowCreation() {
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    "taskList",
 				WorkflowTypeName:            "wType",
 				WorkflowTimeout:             20,
@@ -231,6 +232,7 @@ func (s *ExecutionManagerSuiteForEventsV2) TestWorkflowCreationWithVersionHistor
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    "taskList",
 				WorkflowTypeName:            "wType",
 				WorkflowTimeout:             20,
@@ -363,6 +365,7 @@ func (s *ExecutionManagerSuiteForEventsV2) TestContinueAsNew() {
 				DomainID:                    updatedInfo.DomainID,
 				WorkflowID:                  newWorkflowExecution.GetWorkflowID(),
 				RunID:                       newWorkflowExecution.GetRunID(),
+				FirstExecutionRunID:         updatedInfo.FirstExecutionRunID,
 				TaskList:                    updatedInfo.TaskList,
 				WorkflowTypeName:            updatedInfo.WorkflowTypeName,
 				WorkflowTimeout:             updatedInfo.WorkflowTimeout,

diff --git a/common/persistence/persistence-tests/persistenceTestBase.go b/common/persistence/persistence-tests/persistenceTestBase.go
@@ -336,6 +336,7 @@ func (s *TestBase) CreateWorkflowExecutionWithBranchToken(
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				TaskList:                    taskList,
 				WorkflowTypeName:            wType,
 				WorkflowTimeout:             wTimeout,
@@ -410,6 +411,7 @@ func (s *TestBase) CreateChildWorkflowExecution(ctx context.Context, domainID st
 				DomainID:                    domainID,
 				WorkflowID:                  workflowExecution.GetWorkflowID(),
 				RunID:                       workflowExecution.GetRunID(),
+				FirstExecutionRunID:         workflowExecution.GetRunID(),
 				ParentDomainID:              parentDomainID,
 				ParentWorkflowID:            parentExecution.GetWorkflowID(),
 				ParentRunID:                 parentExecution.GetRunID(),
@@ -532,6 +534,7 @@ func (s *TestBase) ContinueAsNewExecution(
 				DomainID:                    updatedInfo.DomainID,
 				WorkflowID:                  newExecution.GetWorkflowID(),
 				RunID:                       newExecution.GetRunID(),
+				FirstExecutionRunID:         updatedInfo.FirstExecutionRunID,
 				TaskList:                    updatedInfo.TaskList,
 				WorkflowTypeName:            updatedInfo.WorkflowTypeName,
 				WorkflowTimeout:             updatedInfo.WorkflowTimeout,

diff --git a/common/persistence/serialization/getters.go b/common/persistence/serialization/getters.go
@@ -868,6 +868,14 @@ func (w *WorkflowExecutionInfo) GetHasRetryPolicy() (o bool) {
 	return
 }
 
+// GetFirstExecutionRunID internal sql blob getter
+func (w *WorkflowExecutionInfo) GetFirstExecutionRunID() (o []byte) {
+	if w != nil {
+		return w.FirstExecutionRunID
+	}
+	return
+}
+
 // GetVersion internal sql blob getter
 func (a *ActivityInfo) GetVersion() (o int64) {
 	if a != nil {

diff --git a/common/persistence/serialization/interfaces.go b/common/persistence/serialization/interfaces.go
@@ -161,6 +161,7 @@ type (
 		Memo                               map[string][]byte
 		VersionHistories                   []byte
 		VersionHistoriesEncoding           string
+		FirstExecutionRunID                UUID
 	}
 
 	// ActivityInfo blob in a serialization agnostic format