diff --git a/runner/sidecar/sources.go b/runner/sidecar/sources.go
index c96be7cf..5b0af32f 100644
--- a/runner/sidecar/sources.go
+++ b/runner/sidecar/sources.go
@@ -120,10 +120,13 @@ func connectSources(ctx context.Context, process func(context.Context, []byte) e
 						return nil
 					}
 					giveUp := backoff.Steps <= 0
-					logger.Error(err, "failed to send process message", "source", sourceName, "backoffSteps", backoff.Steps, "giveUp", giveUp)
+					logger := logger.WithValues("source", sourceName, "backoffSteps", backoff.Steps, "giveUp", giveUp)
 					if giveUp {
+						logger.Error(err, "failed to send process message")
 						errorsCounter.WithLabelValues(sourceName, fmt.Sprint(replica)).Inc()
 						return err
+					} else {
+						logger.Info("failed to send process message", "err", err.Error())
 					}
 					time.Sleep(backoff.Step())
 				}