282
identity string,
283
result *commonpb.Payloads,
285
>
event := b.createHistoryEvent(enumspb.EVENT_TYPE_ACTIVITY_TASK_COMPLETED, b.timeSource.Now())
286
>
event.Attributes = &historypb.HistoryEvent_ActivityTaskCompletedEventAttributes{
287
>
ActivityTaskCompletedEventAttributes: &historypb.ActivityTaskCompletedEventAttributes{
288
>
ScheduledEventId: scheduledEventID,
289
>
StartedEventId: startedEventID,
290
>
Result: result,
291
>
Identity: identity,
292
>
},
293
>
}
294
>
return event
295
>
}
296
297
func (b *EventFactory) CreateActivityTaskFailedEvent(