identify retryTimeout + placeholder for err handler

smartcontractkit · Feb 14, 2024 · cb19d4b · cb19d4b
1 parent bb12ee9
commit cb19d4b
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/mercury/streams/streams.go b/core/services/ocr2/plugins/ocr2keeper/evmregistry/v21/mercury/streams/streams.go
@@ -15,6 +15,7 @@ import (
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/patrickmn/go-cache"
 
+	"github.com/smartcontractkit/chainlink-automation/pkg/v3/types"
 	"github.com/smartcontractkit/chainlink-common/pkg/services"
 	ocr2keepers "github.com/smartcontractkit/chainlink-common/pkg/types/automation"
 
@@ -251,6 +252,19 @@ func (s *streams) DoMercuryRequest(ctx context.Context, lookup *mercury.StreamsL
 		checkResults[i].RetryInterval = retryInterval
 		checkResults[i].PipelineExecutionState = uint8(state)
 		checkResults[i].IneligibilityReason = uint8(reason)
+		retryTimeout := retryInterval == mercury.RetryIntervalTimeout
+		if retryTimeout {
+			// in case of retry timeout, setting retryable to false
+			checkResults[i].Retryable = false
+		}
+		upkeepType := core.GetUpkeepType(checkResults[i].UpkeepID)
+		switch state {
+		case encoding.MercuryFlakyFailure:
+			if retryTimeout && upkeepType == types.LogTrigger && retryable {
+				// TODO: prepare for error handler
+			}
+		default:
+		}
 		return nil, err
 	}