From e244128812ee90c2586413009578e29ffd452c6a Mon Sep 17 00:00:00 2001 From: Sam Davies Date: Tue, 12 Nov 2024 12:34:23 -0500 Subject: [PATCH] Continue to log stream values on VerboseLogging --- core/services/llo/data_source.go | 4 ++++ 1 file changed, 4 insertions(+) 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 {