diff --git a/core/services/llo/data_source.go b/core/services/llo/data_source.go index 8f35eabbd02..a4d8652660e 100644 --- a/core/services/llo/data_source.go +++ b/core/services/llo/data_source.go @@ -175,6 +175,10 @@ func (d *dataSource) Observe(ctx context.Context, streamValues llo.StreamValues, lggr := logger.With(d.lggr, "elapsed", elapsed, "nSuccessfulStreams", len(successfulStreamIDs), "nFailedStreams", len(failedStreamIDs), "successfulStreamIDs", successfulStreamIDs, "failedStreamIDs", failedStreamIDs, "errs", errStrs, "configDigest", opts.ConfigDigest(), "seqNr", opts.OutCtx().SeqNr) + if opts.VerboseLogging() { + lggr = logger.With(lggr, "streamValues", streamValues) + } + if len(errs) == 0 && opts.VerboseLogging() { lggr.Infow("Observation succeeded for all streams") } else if len(errs) > 0 {