42
}
43
44
>
var attemptStartedTime time.Time
api.go
45
>
var firstScheduledTime time.Time
46
>
var taskQueue string
47
>
var workflowTypeName string
48
>
var closed bool
49
>
var versioningBehavior enumspb.VersioningBehavior
50
>
err = api.GetAndUpdateWorkflowWithNew(
51
>
ctx,
52
>
token.Clock,
53
>
definition.NewWorkflowKey(
54
>
token.NamespaceId,
55
>
token.WorkflowId,
56
>
token.RunId,
57
>
),
58
>
func(workflowLease api.WorkflowLease) (*api.UpdateWorkflowAction, error) {
59
mutableState := workflowLease.GetMutableState()
60
workflowTypeName = mutableState.GetWorkflowType().GetName()