Skip to content

Commit

Permalink
Continue to log stream values on VerboseLogging
Browse files Browse the repository at this point in the history
  • Loading branch information
samsondav committed Nov 12, 2024
1 parent 6b15a2b commit e244128
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions core/services/llo/data_source.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit e244128

Please sign in to comment.