251
}
252
253
>
func (d FailedEventDefinition) Apply(ctx chasm.MutableContext, wf *Workflow, event *historypb.HistoryEvent) error {
nexus_events.go
254
>
attrs := event.GetNexusOperationFailedEventAttributes()
255
>
field, ok := wf.Operations[attrs.GetScheduledEventId()]
256
>
if !ok {
257
return serviceerror.NewNotFoundf("nexus operation not found for scheduled event ID %d", attrs.GetScheduledEventId())
258
}
260
>
261
>
completeTime := event.GetEventTime().AsTime()
262
>
if err := nexusoperation.TransitionFailed.Apply(op, ctx, nexusoperation.EventFailed{
263
>
CompleteTime: &completeTime,
264
>
Failure: attrs.GetFailure().GetCause(),
265
>
}); err != nil {
266
return err
267
}
269
>
return nil
270
}
271