190
return
191
}
192
>
if !atomic.CompareAndSwapInt32(&e.taskState, taskStatePending, taskStateNacked) {
executable_task.go
193
e.Nack(err) // retry nack
194
}
195
197
>
"replication task: %v encountered nack event",
198
>
e.taskID,
199
>
), tag.Error(err))
200
>
now := time.Now().UTC()
201
>
e.emitFinishMetrics(now)
202
>
203
>
var namespaceName string
204
>
item := e.namespace.Load()
205
>
if item != nil {
206
namespaceName = item.(namespace.Name).String()
207
}
209
>
1,
210
>
metrics.OperationTag(e.metricsTag),
211
>
metrics.NamespaceTag(namespaceName),
212
>
)
213
}
214