diff --git a/engine/server/engine/centralized_logs/client_implementations/persistent_volume/stream_logs_strategy/per_week_stream_logs_strategy.go b/engine/server/engine/centralized_logs/client_implementations/persistent_volume/stream_logs_strategy/per_week_stream_logs_strategy.go index f5689b9419..90eb246aa7 100644 --- a/engine/server/engine/centralized_logs/client_implementations/persistent_volume/stream_logs_strategy/per_week_stream_logs_strategy.go +++ b/engine/server/engine/centralized_logs/client_implementations/persistent_volume/stream_logs_strategy/per_week_stream_logs_strategy.go @@ -244,7 +244,8 @@ func (strategy *PerWeekStreamLogsStrategy) sendJsonLogLine( // First decode the line var jsonLog JsonLog if err := json.Unmarshal([]byte(jsonLogLineStr), &jsonLog); err != nil { - return stacktrace.Propagate(err, "An error occurred parsing the json log string: %v\n", jsonLogLineStr) + logrus.Warnf("An error occurred parsing the json log string: %v. Skipping sending this log line.", jsonLogLineStr) + return nil } // Then extract the actual log message using the "log" field