261
versioningStamp *commonpb.WorkerVersionStamp,
262
redirectCounter int64,
264
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_ACTIVITY_TASK_STARTED, b.timeSource.Now())
265
>
event.Attributes = &historypb.HistoryEvent_ActivityTaskStartedEventAttributes{
266
>
ActivityTaskStartedEventAttributes: &historypb.ActivityTaskStartedEventAttributes{
267
>
ScheduledEventId: scheduledEventID,
268
>
Attempt: attempt,
269
>
Identity: identity,
270
>
RequestId: requestID,
271
>
LastFailure: lastFailure,
272
>
WorkerVersion: versioningStamp,
273
>
BuildIdRedirectCounter: redirectCounter,
274
>
},
275
>
}
276
>
return event
277
>
}
278
279
func (b *EventFactory) CreateActivityTaskCompletedEvent(