reset engine_test

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(
-				"[email protected]",
-				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))