[CRE][DONTime] Restore rollout flag (#1991)

bolekk · web-flow · commit f5928e7d3aa4 · 2026-04-20T21:26:28.000Z
diff --git a/pkg/workflows/dontime/pb/dontime.pb.go b/pkg/workflows/dontime/pb/dontime.pb.go
diff --git a/pkg/workflows/dontime/pb/dontime.proto b/pkg/workflows/dontime/pb/dontime.proto
@@ -5,7 +5,8 @@ option go_package = "github.com/smartcontractkit/chainlink-common/pkg/workflows/
 message Observation {
   int64 timestamp = 1;
   map<string, int64> requests = 2;
-  reserved 3; // old rollout flag 'prune_executions'
+  // Flag to roll out execution pruning fix. Can be removed after rollout (once unused in the outcome phase).
+  bool prune_executions = 3;
 }
 
 message ObservedDonTimes {
diff --git a/pkg/workflows/dontime/plugin.go b/pkg/workflows/dontime/plugin.go
@@ -147,8 +147,9 @@ func (p *Plugin) Observation(_ context.Context, outctx ocr3types.OutcomeContext,
 	}
 
 	observation := &pb.Observation{
-		Timestamp: time.Now().UTC().UnixMilli(),
-		Requests:  requests,
+		Timestamp:       time.Now().UTC().UnixMilli(),
+		Requests:        requests,
+		PruneExecutions: true,
 	}
 
 	return proto.MarshalOptions{Deterministic: true}.Marshal(observation)

Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,8 @@ option go_package = "github.com/smartcontractkit/chainlink-common/pkg/workflows/`
`5`	`5`	`message Observation {`
`6`	`6`	`int64 timestamp = 1;`
`7`	`7`	`map<string, int64> requests = 2;`
`8`		`- reserved 3; // old rollout flag 'prune_executions'`
	`8`	`+ // Flag to roll out execution pruning fix. Can be removed after rollout (once unused in the outcome phase).`
	`9`	`+ bool prune_executions = 3;`
`9`	`10`	`}`
`10`	`11`
`11`	`12`	`message ObservedDonTimes {`
Original file line number	Diff line number	Diff line change
`@@ -147,8 +147,9 @@ func (p *Plugin) Observation(_ context.Context, outctx ocr3types.OutcomeContext,`
`147`	`147`	`}`
`148`	`148`
`149`	`149`	`observation := &pb.Observation{`
`150`		`- Timestamp: time.Now().UTC().UnixMilli(),`
`151`		`- Requests: requests,`
	`150`	`+ Timestamp: time.Now().UTC().UnixMilli(),`
	`151`	`+ Requests: requests,`
	`152`	`+ PruneExecutions: true,`
`152`	`153`	`}`
`153`	`154`
`154`	`155`	`return proto.MarshalOptions{Deterministic: true}.Marshal(observation)`