320
timeoutFailure *failurepb.Failure,
321
retryState enumspb.RetryState,
323
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_ACTIVITY_TASK_TIMED_OUT, b.timeSource.Now())
324
>
event.Attributes = &historypb.HistoryEvent_ActivityTaskTimedOutEventAttributes{
325
>
ActivityTaskTimedOutEventAttributes: &historypb.ActivityTaskTimedOutEventAttributes{
326
>
ScheduledEventId: scheduledEventID,
327
>
StartedEventId: startedEventID,
328
>
Failure: timeoutFailure,
329
>
RetryState: retryState,
330
>
},
331
>
}
332
>
return event
333
>
}
334
335
func (b *EventFactory) CreateCompletedWorkflowEvent(