292
identity := workflowTaskIdentity{schedID: schedID, attempt: attempt, version: c.startedWorkflowTaskIdentity().version}
293
if c.taskCompletionBuffer == nil || c.taskCompletionBuffer.identity != identity {
294
>
metrics.WorkflowTaskCompletionBufferLost.With(c.metricsHandler).Record(1)
context.go
295
>
return nil, serviceerror.NewWorkflowTaskCompletionBufferLostf(
296
>
"workflow task completion buffer lost for scheduled event %d attempt %d", schedID, attempt)
297
>
}
298
// Every page in 0..finalPageNumber-1 must be present. A gap means a page was
299
// lost or never sent; merging anyway would silently drop commands.