From ad6dcae1514146a7b1860739c7403961b778b361 Mon Sep 17 00:00:00 2001
From: Michael Street <5597260+MStreet3@users.noreply.github.com>
Date: Tue, 4 Mar 2025 18:42:30 -0500
Subject: [PATCH] reset engine_test

---
 core/services/workflows/engine_test.go | 56 --------------------------
 1 file changed, 56 deletions(-)

diff --git a/core/services/workflows/engine_test.go b/core/services/workflows/engine_test.go
index 3b68c070190..85413e522de 100644
--- a/core/services/workflows/engine_test.go
+++ b/core/services/workflows/engine_test.go
@@ -570,62 +570,6 @@ func TestEngine_RateLimit(t *testing.T) {
 		}
 	})
 
-	t.Run("per workflow ID rate limit", func(t *testing.T) {
-		ctx := testutils.Context(t)
-		reg := coreCap.NewRegistry(logger.TestLogger(t))
-
-		trigger, _ := mockTrigger(t)
-		require.NoError(t, reg.Add(ctx, trigger))
-		require.NoError(t, reg.Add(ctx, mockConsensus("")))
-		target1 := mockTarget("")
-		require.NoError(t, reg.Add(ctx, target1))
-
-		target2 := newMockCapability(
-			capabilities.MustNewCapabilityInfo(
-				"write_ethereum-testnet-sepolia@1.0.0",
-				capabilities.CapabilityTypeTarget,
-				"a write capability targeting ethereum sepolia testnet",
-			),
-			func(req capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error) {
-				m := req.Inputs.Underlying["report"].(*values.Map)
-				return capabilities.CapabilityResponse{
-					Value: m,
-				}, nil
-			},
-		)
-		require.NoError(t, reg.Add(ctx, target2))
-
-		setRateLimiter := func(c *Config) {
-			rl, err := ratelimiter.NewRateLimiter(ratelimiter.Config{
-				GlobalRPS:      1000.0,
-				GlobalBurst:    1000,
-				PerSenderRPS:   1.0,
-				PerSenderBurst: 1,
-			})
-			require.NoError(t, err)
-			c.RateLimiter = rl
-		}
-
-		eng, testHooks := newTestEngineWithYAMLSpec(
-			t,
-			reg,
-			hardcodedWorkflow,
-			setRateLimiter,
-		)
-
-		// Call RateLimiter once with the test workflow ID, so next execution gets rate limited
-		senderAllow, globalAllow := eng.ratelimiter.Allow(testWorkflowID)
-		require.True(t, senderAllow)
-		require.True(t, globalAllow)
-		servicetest.Run(t, eng)
-
-		select {
-		case <-testHooks.rateLimited:
-		case <-ctx.Done():
-			t.FailNow()
-		}
-	})
-
 	t.Run("global rate limit", func(t *testing.T) {
 		ctx := testutils.Context(t)
 		reg := coreCap.NewRegistry(logger.TestLogger(t))