Struct PythonRuntime 

pub struct PythonRuntime { /* private fields */ }

Long-lived Python REPL.

Implementations

impl PythonRuntime

pub async fn new() -> Result<Self, String>

Spawn a REPL with no context variable and no LLM helpers wired up. Used by the agent loop for inline repl blocks the model emits in regular conversation.

pub fn with_state_path(_path: PathBuf) -> Self

Compatibility shim — older RLM code path used to pass a state file. The state file is no longer used, but the path doubles as an extra scratch location callers can rely on for cleanup symmetry.

pub async fn spawn_with_context(context_path: &Path) -> Result<Self, String>

Spawn a REPL with the long input preloaded from a file. Used by the RLM turn loop.

pub async fn execute(&mut self, code: &str) -> Result<ReplRound, String>

Execute a Python code block with no RPC dispatcher. Used for inline repl blocks where llm_query() should fall back to a sentinel.

pub async fn replace_context(&mut self, body: &str) -> Result<(), String>

Replace the long context visible to bounded helpers without restarting the Python process. User-created variables, imports, and handles stay alive across the refresh, which is what lets the normal agent loop use one working kernel instead of rebuilding a throwaway REPL each turn.

The payload travels through a temporary file rather than a generated Python string so large transcripts neither bloat the command stream nor acquire quoting semantics. The old owned file is released only after the kernel has successfully loaded the replacement.

pub async fn run<D>( &mut self, code: &str, bridge: Option<&D>, ) -> Result<ReplRound, String>

where D: RpcDispatcher + ?Sized,

Execute a code block, dispatching any sub-LLM RPCs through bridge.

Returns once Python emits __RLM_DONE_<sid>__ or the round timeout elapses (whichever happens first).

pub fn round_count(&self) -> u64

Total rounds executed.

pub fn round_timeout(&self) -> Option<Duration>

Current per-round timeout policy. RLM context runs intentionally return None so long map-reduce jobs are not killed by the old 180s cap.

pub fn uptime(&self) -> Duration

Wall-clock uptime since spawn.

pub async fn shutdown(self)

Cleanly tear down the subprocess.

Trait Implementations

impl Debug for PythonRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for PythonRuntime

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.