598
metrics.TaskCorruptionCounter.With(e.chasmMetricsHandler).Record(1)
599
if e.dlqEnabled() {
600
>
// Keep this message in sync with the log line mentioned in Investigation section of docs/admin/dlq.md
executable.go
601
>
e.logger.Error("Marking task as terminally failed, will send to DLQ", tag.Error(err), tag.ErrorType(err))
602
>
e.terminalFailureCause = err // <- Execute() examines this attribute on the next attempt.
603
>
metrics.TaskTerminalFailures.With(e.chasmMetricsHandler).Record(1)
604
>
return fmt.Errorf("%w: %v", ErrTerminalTaskFailure, err)
605
>
}
606
e.logger.Error("Dropping task due to terminal error", tag.Error(err), tag.ErrorType(err))
607
return nil