78
)
79
if err != nil {
80
>
// When standby task executor executes task in active cluster (and vice versa),
ndc_task_util.go
81
>
// mutable state might be already deleted by active task executor and NotFound is a valid case which shouldn't be logged.
82
>
// Unfortunately, this will also skip logging of actual errors that might happen due to serious bugs,
83
>
// but these errors, most likely, will happen for other task types too, and will be logged.
84
>
// TODO: remove this logic multi-cursor is implemented and only one task processor is running in each cluster.
85
>
skipNotFoundLog :=
86
>
transferTask.GetType() == enumsspb.TASK_TYPE_TRANSFER_CLOSE_EXECUTION ||
87
>
transferTask.GetType() == enumsspb.TASK_TYPE_TRANSFER_DELETE_EXECUTION
88
>
89
>
if !skipNotFoundLog {
90
>
switch err.(type) {
91
case *serviceerror.NotFound:
92
// NotFound error will be ignored by task error handling logic, so log it here