109
attempt int32,
110
scheduleTime time.Time,
112
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_TASK_SCHEDULED, scheduleTime)
113
>
event.Attributes = &historypb.HistoryEvent_WorkflowTaskScheduledEventAttributes{
114
>
WorkflowTaskScheduledEventAttributes: &historypb.WorkflowTaskScheduledEventAttributes{
115
>
TaskQueue: taskQueue,
116
>
StartToCloseTimeout: startToCloseTimeout,
117
>
Attempt: attempt,
118
>
},
119
>
}
120
>
121
>
return event
122
>
}
123
124
func (b *EventFactory) CreateWorkflowTaskStartedEvent(