210
forkEventVersion int64,
211
checksum string,
213
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_TASK_FAILED, b.timeSource.Now())
214
>
event.Attributes = &historypb.HistoryEvent_WorkflowTaskFailedEventAttributes{
215
>
WorkflowTaskFailedEventAttributes: &historypb.WorkflowTaskFailedEventAttributes{
216
>
ScheduledEventId: scheduledEventID,
217
>
StartedEventId: startedEventID,
218
>
Cause: cause,
219
>
Failure: failure,
220
>
Identity: identity,
221
>
BaseRunId: baseRunID,
222
>
NewRunId: newRunID,
223
>
ForkEventVersion: forkEventVersion,
224
>
BinaryChecksum: checksum,
225
>
},
226
>
}
227
>
return event
228
>
}
229
230
func (b *EventFactory) CreateActivityTaskScheduledEvent(