455
// If worker ignored the update request (old SDK or SDK bug), then server rejects this update.
456
// Otherwise, this update will be delivered (and new WT created) again and again.
457
>
workflowTaskHandler.rejectUnprocessedUpdates(
api.go
458
>
ctx,
459
>
currentWorkflowTask.ScheduledEventID,
460
>
request.GetForceCreateNewWorkflowTask(),
461
>
weContext.GetWorkflowKey(),
462
>
request.GetIdentity(),
463
>
)
464
>
465
>
// If the Workflow completed itself, but there are still accepted
466
>
// (but not completed) Updates, they need to be aborted.
467
>
// Reason is always "WorkflowCompleted" because accepted Updates
468
>
// are not moving to continuing runs (if any).
469
>
if !ms.IsWorkflowExecutionRunning() {
470
updateRegistry.AbortAccepted(update.AbortReasonWorkflowCompleted, &effects)
471
}