Make DeltaStage Configurable

integration-tests/benchmark/keeper_test.go

@@ -131,6 +131,7 @@ var (
 	LinkTokenAddress        = getEnv("LINKTOKENADDRESS", "")
 	EthFeedAddress          = getEnv("ETHFEEDADDRESS", "")
 	GasFeedAddress          = getEnv("GASFEEDADDRESS", "")
+	DeltaStageSeconds, _    = strconv.ParseInt(getEnv("DELTASTAGESECONDS", "0"), 0, 64)
 )
 
 type NetworkConfig struct {
@@ -151,6 +152,10 @@ func TestAutomationBenchmark(t *testing.T) {
 	l.Info().Str("Test Name", testName).Str("Test Inputs", os.Getenv("TEST_INPUTS")).Msg("Running Benchmark Test")
 	benchmarkTestNetwork := networkConfig[networkName]
 
+	if DeltaStageSeconds > 0 {
+		benchmarkTestNetwork.deltaStage = time.Duration(DeltaStageSeconds) * time.Second
+	}
+
 	l.Info().Str("Namespace", testEnvironment.Cfg.Namespace).Msg("Connected to Keepers Benchmark Environment")
 
 	chainClient, err := blockchain.NewEVMClient(benchmarkNetwork, testEnvironment, l)
@@ -261,7 +266,7 @@ var networkConfig = map[string]NetworkConfig{
 		funding:    big.NewFloat(ChainlinkNodeFunding),
 	},
 	"ArbitrumGoerli": {
-		upkeepSLA:  int64(20),
+		upkeepSLA:  int64(120),
 		blockTime:  time.Second,
 		deltaStage: time.Duration(0),
 		funding:    big.NewFloat(ChainlinkNodeFunding),

integration-tests/testsetups/keeper_benchmark.go

@@ -125,6 +125,7 @@ func (k *KeeperBenchmarkTest) Setup(env *environment.Environment) {
 	k.keeperConsumerContracts = make([]contracts.AutomationConsumerBenchmark, len(inputs.RegistryVersions))
 	k.upkeepIDs = make([][]*big.Int, len(inputs.RegistryVersions))
 	k.log.Debug().Interface("TestInputs", inputs).Msg("Setting up benchmark test")
+	k.log.Info().Str("Network", inputs.BlockchainClient.GetNetworkName()).Dur("DeltaStage", inputs.DeltaStage).Msg("Starting Keeper Benchmark Test Setup")
 
 	var err error
 	// Connect to networks and prepare for contract deployment