370
retryState enumspb.RetryState,
371
newExecutionRunID string,
373
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_TIMED_OUT, b.timeSource.Now())
374
>
event.Attributes = &historypb.HistoryEvent_WorkflowExecutionTimedOutEventAttributes{
375
>
WorkflowExecutionTimedOutEventAttributes: &historypb.WorkflowExecutionTimedOutEventAttributes{
376
>
RetryState: retryState,
377
>
NewExecutionRunId: newExecutionRunID,
378
>
},
379
>
}
380
>
return event
381
>
}
382
383
func (b *EventFactory) CreateWorkflowExecutionTerminatedEvent(