diff --git a/pkg/workflows/dontime/plugin.go b/pkg/workflows/dontime/plugin.go index 4cd521c630..3fa5d2f928 100644 --- a/pkg/workflows/dontime/plugin.go +++ b/pkg/workflows/dontime/plugin.go @@ -99,6 +99,11 @@ func (p *Plugin) Observation(_ context.Context, outctx ocr3types.OutcomeContext, requests[req.WorkflowExecutionID] = int64(req.SeqNum) } + p.lggr.Infow("Observation built", + "requestsIncluded", len(requests), + "pendingRequestsInStore", len(p.store.GetRequests()), + ) + observation := &pb.Observation{ Timestamp: time.Now().UTC().UnixMilli(), Requests: requests, @@ -214,6 +219,7 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t p.lggr.Infow("Outcome computed", "observedDonTimesEntries", len(outcome.ObservedDonTimes), "outcomeSizeBytes", len(outcomeBytes), + "pendingRequestsInStore", len(p.store.GetRequests()), ) return outcomeBytes, err } diff --git a/pkg/workflows/dontime/transmitter.go b/pkg/workflows/dontime/transmitter.go index c9d30c3a5f..9ecd46248e 100644 --- a/pkg/workflows/dontime/transmitter.go +++ b/pkg/workflows/dontime/transmitter.go @@ -40,8 +40,7 @@ func (t *Transmitter) Transmit(_ context.Context, _ types.ConfigDigest, _ uint64 t.store.replaceDonTimes(currentDonTimes) t.store.setLastObservedDonTime(outcome.Timestamp) - t.lggr.Infow("Transmitting timestamps", "lastObservedDonTime", outcome.Timestamp) - + responsesDelivered := 0 for executionID, donTimes := range outcome.ObservedDonTimes { request := t.store.GetRequest(executionID) if request == nil { @@ -59,9 +58,16 @@ func (t *Transmitter) Transmit(_ context.Context, _ types.ConfigDigest, _ uint64 Timestamp: donTime, Err: nil, }) + responsesDelivered++ } } + t.lggr.Infow("Transmitting timestamps", + "lastObservedDonTime", outcome.Timestamp, + "observedDonTimesEntries", len(outcome.ObservedDonTimes), + "responsesDelivered", responsesDelivered, + ) + return nil }