1105
}
1106
1107
>
err := newExecutionParams.executionContext.CreateWorkflowExecution(
chasm_engine.go
1108
>
ctx,
1109
>
shardContext,
1110
>
persistence.CreateWorkflowModeUpdateCurrent,
1111
>
currentRunInfo.RunID,
1112
>
currentRunInfo.LastWriteVersion,
1113
>
newExecutionParams.mutableState,
1114
>
newExecutionParams.snapshot,
1115
>
newExecutionParams.events,
1116
>
historyi.TransactionPolicyActive,
1117
>
)
1118
>
if err != nil {
1119
return chasm.StartExecutionResult{}, err
1120
}
1121
1122
>
e.setContextMetadataFromMutableState(ctx, newExecutionParams.mutableState)
chasm_engine.go
1123
>
1124
>
serializedRef, err := newExecutionParams.executionRef.Serialize(e.registry)
1125
>
if err != nil {
1126
return chasm.StartExecutionResult{ExecutionKey: newExecutionParams.executionRef.ExecutionKey, Created: true}, err
1127
}
1129
>
ExecutionKey: newExecutionParams.executionRef.ExecutionKey,
1130
>
ExecutionRef: serializedRef,
1131
>
Created: true,
1132
>
}, nil
1133
}
1134