301
retryState enumspb.RetryState,
302
identity string,
304
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_ACTIVITY_TASK_FAILED, b.timeSource.Now())
305
>
event.Attributes = &historypb.HistoryEvent_ActivityTaskFailedEventAttributes{
306
>
ActivityTaskFailedEventAttributes: &historypb.ActivityTaskFailedEventAttributes{
307
>
ScheduledEventId: scheduledEventID,
308
>
StartedEventId: startedEventID,
309
>
Failure: failure,
310
>
RetryState: retryState,
311
>
Identity: identity,
312
>
},
313
>
}
314
>
return event
315
>
}
316
317
func (b *EventFactory) CreateActivityTaskTimedOutEvent(