Function e2b_semaphore

catalog/code/:exec/python/backend.rs:77–88

Global per-replica concurrency gate for E2B sandbox creation. Enforced across all concurrent ExecPython executions in a single node-runner process. Sized from E2B_CONCURRENCY env var (falls back to E2B_DEFAULT_CONCURRENCY).

()

/// across all concurrent ExecPython executions in a single node-runner process.
/// Sized from E2B_CONCURRENCY env var (falls back to E2B_DEFAULT_CONCURRENCY).
fn e2b_semaphore() -> &'static Semaphore {
    static SEM: std::sync::OnceLock<Semaphore> = std::sync::OnceLock::new();
    SEM.get_or_init(|| {
        let n = std::env::var("E2B_CONCURRENCY")
            .ok()
            .and_then(|v| v.parse::<usize>().ok())
            .filter(|&n| n > 0)
            .unwrap_or(E2B_DEFAULT_CONCURRENCY);
        tracing::info!("ExecPython: E2B concurrency cap = {}", n);
        Semaphore::new(n)
    })
}

#[derive(Default)]
pub struct CodeNode;