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