657
)
658
660
>
lastWriteVersion := updateWorkflow.LastWriteVersion
661
>
662
>
// TODO: double encoding execution state? already in updateWorkflow.ExecutionStateBlob
663
>
executionStateDatablob, err := d.serializer.WorkflowExecutionStateToBlob(updateWorkflow.ExecutionState)
664
>
if err != nil {
665
return err
666
}
667
669
>
runID,
670
>
executionStateDatablob.Data,
671
>
executionStateDatablob.EncodingType.String(),
672
>
lastWriteVersion,
673
>
updateWorkflow.ExecutionState.State,
674
>
request.ShardID,
675
>
rowTypeExecution,
676
>
namespaceID,
677
>
workflowID,
678
>
currentRecordRunID,
679
>
defaultVisibilityTimestamp,
680
>
rowTypeExecutionTaskID,
681
>
runID,
682
>
)
683
}
684