505
ctx context.Context,
506
request *SetWorkflowExecutionRequest,
508
>
serializedWorkflowSnapshot, err := m.SerializeWorkflowSnapshot(&request.SetWorkflowSnapshot)
509
>
if err != nil {
510
return nil, err
511
}
512
513
>
archetypeID, _ := m.assertAndConvertArchetypeID(request.ArchetypeID, "SetWorkflowExecution")
execution_manager.go
514
>
newRequest := &InternalSetWorkflowExecutionRequest{
515
>
ShardID: request.ShardID,
516
>
RangeID: request.RangeID,
517
>
518
>
ArchetypeID: archetypeID,
519
>
520
>
SetWorkflowSnapshot: *serializedWorkflowSnapshot,
521
>
}
522
>
523
>
err = m.persistence.SetWorkflowExecution(ctx, newRequest)
524
>
if err != nil {
525
return nil, err
526
}