138
},
139
activitypb.ACTIVITY_EXECUTION_STATUS_STARTED,
140
>
func(a *Activity, ctx chasm.MutableContext, request *historyservice.RecordActivityTaskStartedRequest) error {
statemachine.go
141
>
attempt := a.LastAttempt.Get(ctx)
142
>
attempt.StartedTime = timestamppb.New(ctx.Now(a))
143
>
attempt.StartedStamp = request.GetStamp()
144
>
// Record the first-ever worker pickup time once and never update on retries or resets.
145
>
if a.FirstAttemptStartedTime == nil {
146
>
a.FirstAttemptStartedTime = attempt.GetStartedTime()
147
>
}
148
>
attempt.StartRequestId = request.GetRequestId()
149
>
attempt.LastWorkerIdentity = request.GetPollRequest().GetIdentity()
150
>
attempt.SdkName = ctx.RequestHeader(headers.ClientNameHeaderName)
151
>
attempt.SdkVersion = ctx.RequestHeader(headers.ClientVersionHeaderName)
152
>
if versionDirective := request.GetVersionDirective().GetDeploymentVersion(); versionDirective != nil {
153
attempt.LastDeploymentVersion = &deploymentpb.WorkerDeploymentVersion{
154
BuildId: versionDirective.GetBuildId(),