Renamed InternalWorkflowSnapshot.ExecutionInfo to ExecutionInfoBlob. (#…

…2384) This matches the convention with ExecutionState/ExecutionStateBlob and allows us to add an ExecutionInfo proto.
temporalio · Jan 18, 2022 · 24ca4e8 · 24ca4e8
1 parent 71093d7
commit 24ca4e8
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 8 deletions.
diff --git a/common/persistence/cassandra/util.go b/common/persistence/cassandra/util.go
@@ -175,7 +175,7 @@ func applyWorkflowSnapshotBatchAsReset(
 		namespaceID,
 		workflowID,
 		runID,
-		workflowSnapshot.ExecutionInfo,
+		workflowSnapshot.ExecutionInfoBlob,
 		workflowSnapshot.ExecutionState,
 		workflowSnapshot.ExecutionStateBlob,
 		workflowSnapshot.NextEventID,
@@ -386,8 +386,8 @@ func createExecution(
 		snapshot.WorkflowID,
 		snapshot.RunID,
 		rowTypeExecution,
-		snapshot.ExecutionInfo.Data,
-		snapshot.ExecutionInfo.EncodingType.String(),
+		snapshot.ExecutionInfoBlob.Data,
+		snapshot.ExecutionInfoBlob.EncodingType.String(),
 		snapshot.ExecutionStateBlob.Data,
 		snapshot.ExecutionStateBlob.EncodingType.String(),
 		snapshot.NextEventID,

diff --git a/common/persistence/execution_manager.go b/common/persistence/execution_manager.go
@@ -586,7 +586,7 @@ func (m *executionManagerImpl) SerializeWorkflowSnapshot(
 		NextEventID:     input.NextEventID,
 	}
 
-	result.ExecutionInfo, err = m.serializer.WorkflowExecutionInfoToBlob(input.ExecutionInfo, enumspb.ENCODING_TYPE_PROTO3)
+	result.ExecutionInfoBlob, err = m.serializer.WorkflowExecutionInfoToBlob(input.ExecutionInfo, enumspb.ENCODING_TYPE_PROTO3)
 	if err != nil {
 		return nil, err
 	}

diff --git a/common/persistence/persistenceInterface.go b/common/persistence/persistenceInterface.go
@@ -426,7 +426,7 @@ type (
 		WorkflowID  string
 		RunID       string
 
-		ExecutionInfo      *commonpb.DataBlob
+		ExecutionInfoBlob  *commonpb.DataBlob
 		ExecutionState     *persistencespb.WorkflowExecutionState
 		ExecutionStateBlob *commonpb.DataBlob
 		StartVersion       int64

diff --git a/common/persistence/size.go b/common/persistence/size.go
@@ -195,7 +195,7 @@ func statusOfInternalWorkflowSnapshot(
 		return nil
 	}
 
-	executionInfoSize := sizeOfBlob(snapshot.ExecutionInfo)
+	executionInfoSize := sizeOfBlob(snapshot.ExecutionInfoBlob)
 	executionStateSize := sizeOfBlob(snapshot.ExecutionStateBlob)
 
 	activityInfoCount := len(snapshot.ActivityInfos)

diff --git a/common/persistence/sql/execution_util.go b/common/persistence/sql/execution_util.go
@@ -245,7 +245,7 @@ func applyWorkflowSnapshotTxAsReset(
 		tx,
 		namespaceID,
 		workflowID,
-		workflowSnapshot.ExecutionInfo,
+		workflowSnapshot.ExecutionInfoBlob,
 		workflowSnapshot.ExecutionState,
 		workflowSnapshot.NextEventID,
 		lastWriteVersion,
@@ -433,7 +433,7 @@ func (m *sqlExecutionStore) applyWorkflowSnapshotTxAsNew(
 		tx,
 		namespaceID,
 		workflowID,
-		workflowSnapshot.ExecutionInfo,
+		workflowSnapshot.ExecutionInfoBlob,
 		workflowSnapshot.ExecutionState,
 		workflowSnapshot.NextEventID,
 		lastWriteVersion,