resonate.scheduler.Scheduler

class documentation

class Scheduler:

Constructor: Scheduler(ctx, pid, unicast, anycast)

Undocumented

Method	`__init__`	Undocumented
Method	`__repr__`	Undocumented
Method	`shutdown`	Undocumented
Method	`step`	Undocumented
Instance Variable	`anycast`	Undocumented
Instance Variable	`computations`	Undocumented
Instance Variable	`ctx`	Undocumented
Instance Variable	`pid`	Undocumented
Instance Variable	`unicast`	Undocumented

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

Undocumented

def __repr__(self) -> str: ¶

Undocumented

def shutdown(self, e: ResonateShutdownError): ¶

Undocumented

def step(self, cmd: Command, future: Future | None = None) -> More | Done: ¶

Undocumented

anycast = ¶

Undocumented

computations: dict[str, Computation] = ¶

Undocumented

ctx = ¶

Undocumented

pid = ¶

Undocumented

unicast = ¶

Undocumented