24
result *commonpb.Payload,
25
links []*commonpb.Link,
27
>
eventID, err := hsm.EventIDFromToken(operation.ScheduledEventToken)
28
>
if err != nil {
29
return err
30
}
31
>
event := node.AddHistoryEvent(enumspb.EVENT_TYPE_NEXUS_OPERATION_COMPLETED, func(e *historypb.HistoryEvent) {
completion.go
32
>
// We must assign to this property, linter doesn't like this.
33
>
// nolint:revive
34
>
e.Attributes = &historypb.HistoryEvent_NexusOperationCompletedEventAttributes{
35
>
NexusOperationCompletedEventAttributes: &historypb.NexusOperationCompletedEventAttributes{
36
>
ScheduledEventId: eventID,
37
>
Result: result,
38
>
RequestId: operation.RequestId,
39
>
},
40
>
}
41
>
e.Links = links
42
>
})
43
>
return CompletedEventDefinition{}.Apply(node.Parent, event)
44
}
45