Function run_in_e2b

catalog/code/:exec/python/backend.rs:552–579

(
    client: &reqwest::Client,
    api_key: &str,
    code: &str,
)

}

async fn run_in_e2b(
    client: &reqwest::Client,
    api_key: &str,
    code: &str,
) -> Result<ExecOutcome, String> {
    // Block here until we have a concurrency slot. The slot is held for the
    // whole sandbox lifetime, including the exec stream and the DELETE call,
    // so we never count more live sandboxes than E2B allows.
    let _permit = e2b_semaphore()
        .acquire()
        .await
        .map_err(|_| "ExecPython semaphore closed (node-runner is shutting down)".to_string())?;

    let handle = create_sandbox_with_retry(client, api_key).await?;

    // Always tear down the sandbox, even if exec failed, so we don't pay for idle.
    let exec_result = exec_in_sandbox(
        client,
        &handle.sandbox_id,
        &handle.envd_token,
        handle.traffic_token.as_deref(),
        code,
    ).await;

    delete_sandbox(client, api_key, &handle.sandbox_id).await;

    exec_result
}

/// Typed E2B JSONL event. Known variants are strict; unknown tags map to
/// `Unknown` which we log and skip. That way a new E2B event type surfaces in