From 2eee49b6b87edb42483ff533fe9980d4e170830d Mon Sep 17 00:00:00 2001 From: Jon Langevin Date: Thu, 26 Feb 2026 15:51:10 -0500 Subject: [PATCH] fix: update pipelinesteps test counts for new DLQ/event/resilience steps Update TestStepFactories and TestPluginLoads to reflect the 28 step factories now registered by the pipeline-steps plugin, including the newly added step.event_publish, step.dlq_send, step.dlq_replay, step.retry_with_backoff, and step.resilient_circuit_breaker. Co-Authored-By: Claude Opus 4.6 --- plugins/pipelinesteps/plugin_test.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/plugins/pipelinesteps/plugin_test.go b/plugins/pipelinesteps/plugin_test.go index f333ae8c..df833648 100644 --- a/plugins/pipelinesteps/plugin_test.go +++ b/plugins/pipelinesteps/plugin_test.go @@ -39,6 +39,7 @@ func TestStepFactories(t *testing.T) { "step.delegate", "step.jq", "step.publish", + "step.event_publish", "step.http_call", "step.request_parse", "step.db_query", @@ -54,6 +55,10 @@ func TestStepFactories(t *testing.T) { "step.cache_delete", "step.ui_scaffold", "step.ui_scaffold_analyze", + "step.dlq_send", + "step.dlq_replay", + "step.retry_with_backoff", + "step.resilient_circuit_breaker", } for _, stepType := range expectedSteps { @@ -75,7 +80,7 @@ func TestPluginLoads(t *testing.T) { } steps := loader.StepFactories() - if len(steps) != 23 { - t.Fatalf("expected 23 step factories after load, got %d", len(steps)) + if len(steps) != 28 { + t.Fatalf("expected 28 step factories after load, got %d", len(steps)) } }