diff --git a/common/persistence/cassandra/util.go b/common/persistence/cassandra/util.go index 273267bc74e..414b9d6cc88 100644 --- 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 index 26183b19c35..01fdedcd1e6 100644 --- a/common/persistence/execution_manager.go +++ b/common/persistence/execution_manager.go @@ -546,7 +546,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 index e6cbc21762a..d3f9f2ed107 100644 --- a/common/persistence/persistenceInterface.go +++ b/common/persistence/persistenceInterface.go @@ -428,7 +428,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 index 3d819fc15d6..d668d1e6a0d 100644 --- 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 index 1211e10a49b..964921f7905 100644 --- 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,