From b210f696e6828b0b00a0262762cb4a4ff426b524 Mon Sep 17 00:00:00 2001 From: De Clercq Wentzel <10665586+wentzeld@users.noreply.github.com> Date: Sat, 14 Feb 2026 16:04:34 -0800 Subject: [PATCH 1/2] wave 1.5 error improvements --- pkg/capabilities/consensus/ocr3/reporting_plugin.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/capabilities/consensus/ocr3/reporting_plugin.go b/pkg/capabilities/consensus/ocr3/reporting_plugin.go index 94ac98c069..3ea83a267b 100644 --- a/pkg/capabilities/consensus/ocr3/reporting_plugin.go +++ b/pkg/capabilities/consensus/ocr3/reporting_plugin.go @@ -359,7 +359,8 @@ func (r *reportingPlugin) Outcome(ctx context.Context, outctx ocr3types.OutcomeC } if len(obs) < (2*r.config.F + 1) { - lggr.Debugw("insufficient observations for workflow execution id") + lggr.Warnw("Insufficient observations for workflow execution: consensus skipped because fewer than 2f+1 nodes reported observations", + "observationCount", len(obs), "requiredCount", 2*r.config.F+1, "workflowExecutionID", weid.WorkflowExecutionId, "workflowID", weid.WorkflowId) continue } From def477726832621cbcc91f05faf25336adb99076 Mon Sep 17 00:00:00 2001 From: De Clercq Wentzel <10665586+wentzeld@users.noreply.github.com> Date: Sun, 15 Feb 2026 10:53:17 -0800 Subject: [PATCH 2/2] Apply suggestion from @Copilot Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- pkg/capabilities/consensus/ocr3/reporting_plugin.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/capabilities/consensus/ocr3/reporting_plugin.go b/pkg/capabilities/consensus/ocr3/reporting_plugin.go index 3ea83a267b..d896a69cd8 100644 --- a/pkg/capabilities/consensus/ocr3/reporting_plugin.go +++ b/pkg/capabilities/consensus/ocr3/reporting_plugin.go @@ -360,7 +360,7 @@ func (r *reportingPlugin) Outcome(ctx context.Context, outctx ocr3types.OutcomeC if len(obs) < (2*r.config.F + 1) { lggr.Warnw("Insufficient observations for workflow execution: consensus skipped because fewer than 2f+1 nodes reported observations", - "observationCount", len(obs), "requiredCount", 2*r.config.F+1, "workflowExecutionID", weid.WorkflowExecutionId, "workflowID", weid.WorkflowId) + "observationCount", len(obs), "requiredCount", 2*r.config.F+1) continue }