3546
}
3547
3549
>
defer cancel()
3550
>
3551
>
recordStartedRequest := &historyservice.RecordActivityTaskStartedRequest{
3552
>
NamespaceId: task.event.Data.GetNamespaceId(),
3553
>
WorkflowExecution: task.workflowExecution(),
3554
>
ScheduledEventId: task.event.Data.GetScheduledEventId(),
3555
>
Clock: task.event.Data.GetClock(),
3556
>
RequestId: uuid.NewString(),
3557
>
PollRequest: pollReq,
3558
>
BuildIdRedirectInfo: task.redirectInfo,
3559
>
Stamp: task.event.Data.GetStamp(),
3560
>
// TODO: stop sending ScheduledDeployment. [cleanup-old-wv]
3561
>
ScheduledDeployment: worker_versioning.DirectiveDeployment(task.event.Data.VersionDirective),
3562
>
VersionDirective: task.event.Data.VersionDirective,
3563
>
TaskDispatchRevisionNumber: task.taskDispatchRevisionNumber,
3564
>
ComponentRef: task.event.Data.GetComponentRef(),
3565
>
}
3566
>
3567
>
return e.historyClient.RecordActivityTaskStarted(ctx, recordStartedRequest)
3568
}
3569