509
workflowTaskCompletedEventID int64,
510
command *commandpb.StartTimerCommandAttributes,
512
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_TIMER_STARTED, b.timeSource.Now())
513
>
event.Attributes = &historypb.HistoryEvent_TimerStartedEventAttributes{
514
>
TimerStartedEventAttributes: &historypb.TimerStartedEventAttributes{
515
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
516
>
TimerId: command.TimerId,
517
>
StartToFireTimeout: command.StartToFireTimeout,
518
>
},
519
>
}
520
>
return event
521
>
}
522
523
func (b *EventFactory) CreateTimerFiredEvent(startedEventID int64, timerID string) *historypb.HistoryEvent {