cre-1601: log improvement

mchain0 · mchain0 · commit 2f2e45d6498b · 2025-12-29T22:18:22.000+01:00
diff --git a/pkg/workflows/ring/plugin.go b/pkg/workflows/ring/plugin.go
@@ -158,7 +158,6 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t
 		return nil, err
 	}
 
-	totalObservations := len(aos)
 	currentShardHealth, allWorkflows, nows := p.collectShardInfo(aos)
 
 	// Need at least F+1 timestamps; fewer means >F faulty nodes and we can't trust this round
@@ -211,7 +210,7 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t
 		Routes: routes,
 	}
 
-	p.lggr.Infow("Consensus Outcome", "healthyShards", healthyShardCount, "totalObservations", totalObservations, "workflowCount", len(routes))
+	p.lggr.Infow("Consensus Outcome", "healthyShards", healthyShardCount, "totalObservations", len(aos), "workflowCount", len(routes))
 
 	return proto.MarshalOptions{Deterministic: true}.Marshal(outcome)
 }

Original file line number	Diff line number	Diff line change
`@@ -158,7 +158,6 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t`
`158`	`158`	`return nil, err`
`159`	`159`	`}`
`160`	`160`
`161`		`- totalObservations := len(aos)`
`162`	`161`	`currentShardHealth, allWorkflows, nows := p.collectShardInfo(aos)`
`163`	`162`
`164`	`163`	`// Need at least F+1 timestamps; fewer means >F faulty nodes and we can't trust this round`
`@@ -211,7 +210,7 @@ func (p *Plugin) Outcome(_ context.Context, outctx ocr3types.OutcomeContext, _ t`
`211`	`210`	`Routes: routes,`
`212`	`211`	`}`
`213`	`212`
`214`		`- p.lggr.Infow("Consensus Outcome", "healthyShards", healthyShardCount, "totalObservations", totalObservations, "workflowCount", len(routes))`
	`213`	`+ p.lggr.Infow("Consensus Outcome", "healthyShards", healthyShardCount, "totalObservations", len(aos), "workflowCount", len(routes))`
`215`	`214`
`216`	`215`	`return proto.MarshalOptions{Deterministic: true}.Marshal(outcome)`
`217`	`216`	`}`