[branch-out] Quarantine Flaky Tests - 2026-01-30

core/services/relay/evm/mercury/persistence_manager_test.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/jmoiron/sqlx"
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
+	"github.com/smartcontractkit/quarantine"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
@@ -64,6 +65,7 @@ func TestPersistenceManager(t *testing.T) {
 }
 
 func TestPersistenceManagerAsyncDelete(t *testing.T) {
+	quarantine.Flaky(t, "DX-2206")
 	ctx := testutils.Context(t)
 	jobID := rand.Int32()
 	db := testutils.NewSqlxDB(t)

integration-tests/smoke/ccip/ccip_rmn_test.go

@@ -48,6 +48,7 @@ import (
 )
 
 func TestRMN_IncorrectSig(t *testing.T) {
+	quarantine.Flaky(t, "DX-2024")
 	runRmnTestCase(t, rmnTestCase{
 		nodesWithIncorrectSigner: []int{0, 1},
 		name:                     "messages with incorrect RMN signature",
@@ -123,6 +124,7 @@ func TestRMN_SimpleVerificationDisabledOnDestination(t *testing.T) {
 }
 
 func TestRMN_TwoMessagesOnTwoLanesIncludingBatchingWithTemporaryPause(t *testing.T) {
+	quarantine.Flaky(t, "DX-2023")
 	runRmnTestCase(t, rmnTestCase{
 		name:        "messages on two lanes including batching",
 		waitForExec: true,
@@ -146,6 +148,7 @@ func TestRMN_TwoMessagesOnTwoLanesIncludingBatchingWithTemporaryPause(t *testing
 }
 
 func TestRMN_MultipleMessagesOnOneLaneNoWaitForExec(t *testing.T) {
+	quarantine.Flaky(t, "DX-2019")
 	runRmnTestCase(t, rmnTestCase{
 		name:        "multiple messages for rmn batching inspection and one rmn node down",
 		waitForExec: false, // do not wait for execution reports
@@ -168,6 +171,7 @@ func TestRMN_MultipleMessagesOnOneLaneNoWaitForExec(t *testing.T) {
 }
 
 func TestRMN_NotEnoughObservers(t *testing.T) {
+	quarantine.Flaky(t, "DX-2017")
 	runRmnTestCase(t, rmnTestCase{
 		name:                "one message but not enough observers, should not get a commit report",
 		passIfNoCommitAfter: 15 * time.Second,
@@ -241,6 +245,7 @@ func TestRMN_NotEnoughSigners(t *testing.T) {
 }
 
 func TestRMN_DifferentRmnNodesForDifferentChains(t *testing.T) {
+	quarantine.Flaky(t, "DX-2142")
 	runRmnTestCase(t, rmnTestCase{
 		name:        "different rmn nodes support different chains",
 		waitForExec: false,
@@ -267,6 +272,7 @@ func TestRMN_DifferentRmnNodesForDifferentChains(t *testing.T) {
 }
 
 func TestRMN_TwoMessagesOneSourceChainCursed(t *testing.T) {
+	quarantine.Flaky(t, "DX-2034")
 	runRmnTestCase(t, rmnTestCase{
 		name:                "two messages, one source chain is cursed the other chain was cursed but curse is revoked",
 		passIfNoCommitAfter: 15 * time.Second,
@@ -1013,6 +1019,7 @@ func performReorgTest(t *testing.T, e testhelpers.DeployedEnv, l logging.Logger,
 }
 
 func Test_CCIPReorg_BelowFinality_OnSource_WithRMN(t *testing.T) {
+	quarantine.Flaky(t, "DX-2717")
 	tc := rmnTestCase{
 		homeChainConfig: homeChainConfig{
 			f: map[int]int{chain0: 1, chain1: 1},
@@ -1056,6 +1063,7 @@ func Test_CCIPReorg_BelowFinality_OnSource_WithRMN(t *testing.T) {
 }
 
 func Test_CCIPReorg_BelowFinality_OnSource_WithRMN_Recover(t *testing.T) {
+	quarantine.Flaky(t, "DX-2718")
 	tc := rmnTestCase{
 		homeChainConfig: homeChainConfig{
 			f: map[int]int{chain0: 1, chain1: 1},
@@ -1104,6 +1112,7 @@ func Test_CCIPReorg_BelowFinality_OnSource_WithRMN_Recover(t *testing.T) {
 }
 
 func Test_CCIPReorg_BelowFinality_OnSource_WithRMN_Block(t *testing.T) {
+	quarantine.Flaky(t, "DX-2719")
 	tc := rmnTestCase{
 		homeChainConfig: homeChainConfig{
 			f: map[int]int{chain0: 1, chain1: 1},

integration-tests/smoke/keeper_test.go

@@ -8,6 +8,8 @@ import (
 	"testing"
 	"time"
 
+	"github.com/smartcontractkit/quarantine"
+
 	"github.com/smartcontractkit/chainlink-common/pkg/utils/tests"
 	"github.com/smartcontractkit/chainlink/integration-tests/utils"
 
@@ -955,6 +957,7 @@ func TestKeeperMigrateRegistry(t *testing.T) {
 }
 
 func TestKeeperNodeDown(t *testing.T) {
+	quarantine.Flaky(t, "DX-2756")
 	t.Parallel()
 	registryVersions := []ethereum.KeeperRegistryVersion{
 		ethereum.RegistryVersion_1_1,

system-tests/tests/go.mod

@@ -80,6 +80,7 @@ require (
 	github.com/smartcontractkit/chainlink/system-tests/tests/smoke/cre/evm/logtrigger v0.0.0-00010101000000-000000000000
 	github.com/smartcontractkit/chainlink/system-tests/tests/smoke/cre/evmread v0.0.0-20250917232237-c4ecf802c6f8
 	github.com/smartcontractkit/libocr v0.0.0-20251212213002-0a5e2f907dda
+	github.com/smartcontractkit/quarantine v0.0.0-20250909213106-ece491bef618
 	github.com/stretchr/testify v1.11.1
 	golang.org/x/sync v0.19.0
 	google.golang.org/protobuf v1.36.11

system-tests/tests/regression/cre/cre_regression_suite_test.go

@@ -5,6 +5,8 @@ import (
 	"strings"
 	"testing"
 
+	"github.com/smartcontractkit/quarantine"
+
 	t_helpers "github.com/smartcontractkit/chainlink/system-tests/tests/test-helpers"
 
 	"github.com/smartcontractkit/chainlink-testing-framework/framework"
@@ -49,6 +51,7 @@ func Test_CRE_V2_Cron_Regression(t *testing.T) {
 }
 
 func Test_CRE_V2_HTTP_Regression(t *testing.T) {
+	quarantine.Flaky(t, "DX-2009")
 	for _, tCase := range httpNegativeTests {
 		testName := "[v2] HTTP Trigger fails with " + tCase.name
 		t.Run(testName, func(t *testing.T) {
@@ -84,6 +87,7 @@ func runEVMNegativeTestSuite(t *testing.T, testCases []evmNegativeTest) {
 }
 
 func Test_CRE_V2_EVM_BalanceAt_Invalid_Address_Regression(t *testing.T) {
+	quarantine.Flaky(t, "DX-2518")
 	runEVMNegativeTestSuite(t, evmNegativeTestsBalanceAtInvalidAddress)
 }
 
@@ -139,6 +143,7 @@ func Test_CRE_V2_EVM_WriteReport_Invalid_Gas_Regression(t *testing.T) {
 }
 
 func Test_CRE_V2_EVM_LogTrigger_Invalid_Address_Regression(t *testing.T) {
+	quarantine.Flaky(t, "DX-2757")
 	runEVMNegativeTestSuite(t, evmNegativeTestsLogTriggerInvalidAddress)
 }
 

system-tests/tests/smoke/cre/cre_suite_test.go

@@ -6,6 +6,8 @@ import (
 
 	"github.com/stretchr/testify/require"
 
+	"github.com/smartcontractkit/quarantine"
+
 	t_helpers "github.com/smartcontractkit/chainlink/system-tests/tests/test-helpers"
 )
 
@@ -69,6 +71,7 @@ func Test_CRE_V1_Billing_EVM_Write(t *testing.T) {
 */
 
 func Test_CRE_V1_Billing_Cron_Beholder(t *testing.T) {
+	quarantine.Flaky(t, "DX-1907")
 	testEnv := t_helpers.SetupTestEnvironmentWithConfig(t, t_helpers.GetDefaultTestConfig(t))
 
 	require.NoError(