resonate.scheduler.Computation

class documentation

class Computation:

Constructor: Computation(id, ctx, pid, unicast, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`__repr__`	Undocumented
Method	`apply`	Undocumented
Method	`eval`	Undocumented
Method	`result`	Undocumented
Method	`runnable`	Undocumented
Method	`subscribe`	Undocumented
Method	`suspendable`	Undocumented
Instance Variable	`anycast`	Undocumented
Instance Variable	`ctx`	Undocumented
Instance Variable	`futures`	Undocumented
Instance Variable	`graph`	Undocumented
Instance Variable	`id`	Undocumented
Instance Variable	`max_len`	Undocumented
Instance Variable	`pid`	Undocumented
Instance Variable	`unicast`	Undocumented
Method	`_apply_notify`	Undocumented
Method	`_apply_receive`	Undocumented
Method	`_apply_resume`	Undocumented
Method	`_apply_retry`	Undocumented
Method	`_apply_return`	Undocumented
Method	`_eval`	Undocumented
Method	`_unblock`	Undocumented

def __init__(self, id: str, ctx: Callable[[str, str, Info], Context], pid: str, unicast: str, anycast: str): ¶

Undocumented

def __repr__(self) -> str: ¶

Undocumented

def apply(self, cmd: Command): ¶

Undocumented

def eval(self) -> More | Done: ¶

Undocumented

def result(self) -> Result[Any] | None: ¶

Undocumented

def runnable(self) -> bool: ¶

Undocumented

def subscribe(self, future: Future): ¶

Undocumented

def suspendable(self) -> bool: ¶

Undocumented

anycast = ¶

Undocumented

ctx = ¶

Undocumented

futures: PoppableList[Future] = ¶

Undocumented

graph = ¶

Undocumented

id = ¶

Undocumented

max_len: Final[int] = ¶

Undocumented

pid = ¶

Undocumented

unicast = ¶

Undocumented

def _apply_notify(self, node: Node[State], promise: DurablePromise): ¶

Undocumented

def _apply_receive(self, node: Node[State], promise: DurablePromise): ¶

Undocumented

def _apply_resume(self, node: Node[State], promise: DurablePromise): ¶

Undocumented

def _apply_retry(self, node: Node[State]): ¶

Undocumented

def _apply_return(self, node: Node[State], result: Result[Any]): ¶

Undocumented

def _eval(self, node: Node[State]) ->

list[Function | Delayed[Function | Retry] | Network[CreatePromiseReq | ResolvePromiseReq | RejectPromiseReq | CancelPromiseReq]]

: ¶

Undocumented

def _unblock(self, nodes: list[Node[State]], next: AWT | Result[Any]): ¶

Undocumented