56
),
57
func(workflowLease api.WorkflowLease) (*api.UpdateWorkflowAction, error) {
58
>
mutableState := workflowLease.GetMutableState()
api.go
59
>
workflowTypeName = mutableState.GetWorkflowType().GetName()
60
>
if !mutableState.IsWorkflowExecutionRunning() {
61
return nil, consts.ErrWorkflowCompleted
62
}
63
64
>
scheduledEventID := token.GetScheduledEventId()
api.go
65
>
isCompletedByID := false
66
>
if scheduledEventID == common.EmptyEventID { // client call CompleteActivityById, so get scheduledEventID by activityID
67
isCompletedByID = true
68
scheduledEventID, err0 = api.GetActivityScheduledEventID(token.GetActivityId(), mutableState)