354
command *commandpb.FailWorkflowExecutionCommandAttributes,
355
newExecutionRunID string,
357
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_FAILED, b.timeSource.Now())
358
>
event.Attributes = &historypb.HistoryEvent_WorkflowExecutionFailedEventAttributes{
359
>
WorkflowExecutionFailedEventAttributes: &historypb.WorkflowExecutionFailedEventAttributes{
360
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
361
>
Failure: command.Failure,
362
>
RetryState: retryState,
363
>
NewExecutionRunId: newExecutionRunID,
364
>
},
365
>
}
366
>
return event
367
>
}
368
369
func (b *EventFactory) CreateTimeoutWorkflowEvent(