57
),
58
func(workflowLease api.WorkflowLease) (resp *api.UpdateWorkflowAction, retErr error) {
60
>
if !mutableState.IsWorkflowExecutionRunning() {
61
return nil, consts.ErrWorkflowCompleted
62
}
63
65
>
ctx, shardContext, mutableState, request, matchingClient, routingInfoCache,
66
>
)
67
>
if err != nil {
68
return nil, err
69
}
70
72
>
Noop: false,
73
>
// Create new wft if a transition started with this activity.
74
>
// StartDeploymentTransition rescheduled pending wft, but this creates new
75
>
// one if there is no pending wft.
76
>
CreateWorkflowTask: rejectCode == rejectCodeStartedTransition,
77
>
}, nil
78
},
79
nil,