temp

Author: LouisTsai-Csie

packages/testing/src/execution_testing/cli/pytest_commands/plugins/execute/execute.py

@@ -138,6 +138,17 @@ def pytest_addoption(parser: pytest.Parser) -> None:
         default=False,
         help="Don't send transactions, just print the minimum balance required per test.",
     )
+    execute_group.addoption(
+        "--max-tx-per-batch",
+        action="store",
+        dest="max_tx_per_batch",
+        type=int,
+        default=None,
+        help=(
+            "Maximum number of transactions to send in a single batch to the RPC. "
+            "Default=750. Higher values may cause RPC instability."
+        ),
+    )
 
     report_group = parser.getgroup(
         "tests", "Arguments defining html report behavior"
@@ -311,6 +322,12 @@ def dry_run(request: pytest.FixtureRequest) -> bool:
     return request.config.getoption("dry_run")
 
 
+@pytest.fixture(scope="session")
+def max_transactions_per_batch(request: pytest.FixtureRequest) -> int | None:
+    """Return the maximum number of transactions per batch, or None for default."""
+    return request.config.getoption("max_tx_per_batch")
+
+
 @pytest.fixture(scope="session")
 def default_max_fee_per_gas(
     request: pytest.FixtureRequest,

packages/testing/src/execution_testing/execution/transaction_post.py

@@ -23,6 +23,9 @@
 
 logger = get_logger(__name__)
 
+# Threshold above which RPC service may become unstable
+RPC_OVERLOAD_THRESHOLD = 1000
+
 
 class TransactionPost(BaseExecute):
     """
@@ -38,6 +41,8 @@ class TransactionPost(BaseExecute):
     skip_gas_used_validation: bool = (
         False  # Skip gas validation even if expected is set
     )
+    # Transaction batching to avoid RPC overload
+    max_transactions_per_batch: int = 750
 
     format_name: ClassVar[str] = "transaction_post_test"
     description: ClassVar[str] = (
@@ -80,6 +85,22 @@ def execute(
         """Execute the format."""
         del fork
         del engine_rpc
+
+        # Check if CLI override for max_transactions_per_batch is provided
+        cli_max_tx_per_batch = request.config.getoption(
+            "max_tx_per_batch", None
+        )
+        if cli_max_tx_per_batch is not None:
+            self.max_transactions_per_batch = cli_max_tx_per_batch
+
+        # Warn if max_transactions_per_batch exceeds safe threshold
+        if self.max_transactions_per_batch > RPC_OVERLOAD_THRESHOLD:
+            logger.warning(
+                f"max_transactions_per_batch ({self.max_transactions_per_batch}) exceeds "
+                f"the safe threshold ({RPC_OVERLOAD_THRESHOLD}). "
+                "This may cause RPC service instability or failures."
+            )
+
         for block in self.blocks:
             for tx in block:
                 if not isinstance(tx, NetworkWrappedTransaction):
@@ -131,8 +152,18 @@ def execute(
                             f"Transaction rejected as expected: {exc_info.value}"
                         )
             else:
-                eth_rpc.send_wait_transactions(signed_txs)
-                all_tx_hashes.extend([tx.hash for tx in signed_txs])
+                # Send transactions in batches to avoid RPC overload
+                batch_size = self.max_transactions_per_batch
+                for i in range(0, len(signed_txs), batch_size):
+                    batch = signed_txs[i : i + batch_size]
+                    logger.info(
+                        f"Sending transaction batch {i // batch_size + 1} "
+                        f"({len(batch)} transactions, "
+                        f"{i + 1}-{min(i + batch_size, len(signed_txs))} "
+                        f"of {len(signed_txs)})"
+                    )
+                    eth_rpc.send_wait_transactions(batch)
+                    all_tx_hashes.extend([tx.hash for tx in batch])
 
         # Perform gas validation if required for benchmarking
         # Ensures benchmark tests consume exactly the expected gas