From 2c8e81633876d2bddfa85473fc24fde7d94c24b8 Mon Sep 17 00:00:00 2001
From: Dylan Tinianov <dylan.tinianov@smartcontract.com>
Date: Thu, 26 Mar 2026 11:03:11 -0400
Subject: [PATCH] Add state logging

---
 pkg/workflows/dontime/plugin.go      |  6 ++++++
 pkg/workflows/dontime/transmitter.go | 10 ++++++++--
 2 files changed, 14 insertions(+), 2 deletions(-)

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
 }