jeevesagent.runtime.inproc

In-process runtime: no durability, no journal.

Every step just runs. Used in dev, tests, and demos. Production users swap in DBOSRuntime or TemporalRuntime (Phase 5).

Classes

InProcRuntime	No durability. Each step runs immediately.
InProcSession	Trivial session: just a holder for the session ID and signals.

Module Contents

class jeevesagent.runtime.inproc.InProcRuntime

No durability. Each step runs immediately.

async session(session_id: str) → collections.abc.AsyncIterator[InProcSession]

async signal(session_id: str, name: str, payload: Any) → None

async step(name: str, fn: collections.abc.Callable[Ellipsis, collections.abc.Awaitable[Any]], *args: Any, idempotency_key: str | None = None, **kwargs: Any) → Any

stream_step(name: str, fn: collections.abc.Callable[Ellipsis, collections.abc.AsyncIterator[Any]], *args: Any, **kwargs: Any) → collections.abc.AsyncIterator[Any]

name = 'inproc'

class jeevesagent.runtime.inproc.InProcSession(session_id: str)

Trivial session: just a holder for the session ID and signals.

async deliver(name: str, payload: Any) → None

id