fix: rename to max_concurrent_asm_proofs to max_concurrent_proofs

Author: prajwolrg

bin/asm-runner/src/bootstrap.rs

@@ -2,10 +2,8 @@ use std::sync::Arc;
 
 use anyhow::Result;
 use bitcoind_async_client::{Auth, Client};
-use moho_recursive_proof::MohoRecursiveProgram;
 use strata_asm_params::AsmParams;
 use strata_asm_proof_db::SledProofDb;
-use strata_asm_proof_impl::program::AsmStfProofProgram;
 use strata_asm_worker::AsmWorkerBuilder;
 use strata_tasks::TaskExecutor;
 use tokio::{
@@ -80,6 +78,8 @@ pub(crate) async fn bootstrap(
 
         #[cfg(not(feature = "sp1"))]
         let (asm, moho) = {
+            use moho_recursive_proof::MohoRecursiveProgram;
+            use strata_asm_proof_impl::program::AsmStfProofProgram;
             (
                 AsmStfProofProgram::native_host(),
                 MohoRecursiveProgram::native_host(),

bin/asm-runner/src/prover/config.rs

@@ -10,8 +10,8 @@ pub(crate) struct OrchestratorConfig {
     /// Interval between orchestrator ticks.
     pub tick_interval: Duration,
 
-    /// Maximum number of concurrent ASM proof jobs in flight.
-    pub max_concurrent_asm_proofs: usize,
+    /// Maximum number of concurrent proof jobs in flight.
+    pub max_concurrent_proofs: usize,
 
     /// Path to the proof database (SledProofDb).
     pub proof_db_path: PathBuf,

bin/asm-runner/src/prover/orchestrator.rs

@@ -213,10 +213,7 @@ impl<R: ZkVmRemoteHost> ProofOrchestrator<R> {
             .context("failed to query in-progress proofs")?
             .len();
 
-        let capacity = self
-            .config
-            .max_concurrent_asm_proofs
-            .saturating_sub(in_flight);
+        let capacity = self.config.max_concurrent_proofs.saturating_sub(in_flight);
 
         if capacity == 0 {
             return Ok(());

functional-tests/envs/prover_env.py

@@ -15,6 +15,6 @@ def _orchestrator_config(self, ectx: flexitest.EnvContext) -> OrchestratorConfig
         proof_db_path = str((envdd_path / "asm_rpc" / "proof_db").resolve())
         return OrchestratorConfig(
             tick_interval=Duration(secs=1, nanos=0),
-            max_concurrent_asm_proofs=4,
+            max_concurrent_proofs=4,
             proof_db_path=proof_db_path,
         )

functional-tests/factory/asm_rpc/config_cfg.py

@@ -43,7 +43,7 @@ class OrchestratorConfig:
     """Proof orchestrator configuration."""
 
     tick_interval: Duration
-    max_concurrent_asm_proofs: int
+    max_concurrent_proofs: int
     proof_db_path: str