297
// The event will be applied before the completion since buffered events are reordered and put at the end of the
298
// batch, after command events from the workflow task.
299
>
event := ms.AddHistoryEvent(enumspb.EVENT_TYPE_NEXUS_OPERATION_CANCEL_REQUESTED, func(he *historypb.HistoryEvent) {
commands.go
300
>
he.Attributes = &historypb.HistoryEvent_NexusOperationCancelRequestedEventAttributes{
301
>
NexusOperationCancelRequestedEventAttributes: &historypb.NexusOperationCancelRequestedEventAttributes{
302
>
ScheduledEventId: attrs.ScheduledEventId,
303
>
WorkflowTaskCompletedEventId: workflowTaskCompletedEventID,
304
>
},
305
>
}
306
>
he.UserMetadata = command.UserMetadata
307
>
he.EventGroupMarkers = command.EventGroupMarkers
308
>
})
309
310
>
err = nexusoperations.CancelRequestedEventDefinition{}.Apply(ms.HSM(), event)
commands.go
311
>
312
>
// Cancel spawns a child Cancelation machine, if that machine already exists we got a duplicate cancelation request.
313
>
if errors.Is(err, hsm.ErrStateMachineAlreadyExists) {
314
return chasmworkflow.FailWorkflowTaskError{
315
Cause: enumspb.WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_NEXUS_OPERATION_ATTRIBUTES,
316
Message: fmt.Sprintf("cancelation was already requested for an operation with scheduled event ID %d", attrs.ScheduledEventId),
317
}
318
>
} else if errors.Is(err, hsm.ErrStateMachineNotFound) {
commands.go
319
// This may happen if there's a buffered completion. Ignore.
320
return nil