diff --git a/integration_tests/test_subscribe.py b/integration_tests/test_subscribe.py
index ed6658a192..1e88dcc1a5 100644
--- a/integration_tests/test_subscribe.py
+++ b/integration_tests/test_subscribe.py
@@ -3,6 +3,7 @@
 import time
 from collections import defaultdict
 
+import pytest
 import websockets
 from eth_utils import abi
 from hexbytes import HexBytes
@@ -81,6 +82,7 @@ async def unsubscribe(self, sub_id):
 TEST_EVENT_TOPIC = Web3.keccak(text="TestEvent(uint256)")
 
 
+@pytest.mark.flaky(max_runs=2)
 def test_subscribe_basic(cronos: Cronos):
     """
     test basic subscribe and unsubscribe