resonate.scheduler.Lfnc

class documentation

class Lfnc:

Undocumented

Method	`__post_init__`	Undocumented
Method	`__repr__`	Undocumented
Method	`map`	Undocumented
Class Variable	`args`	Undocumented
Class Variable	`ccls`	Undocumented
Class Variable	`cid`	Undocumented
Class Variable	`conv`	Undocumented
Class Variable	`func`	Undocumented
Class Variable	`id`	Undocumented
Class Variable	`kwargs`	Undocumented
Class Variable	`opts`	Undocumented
Class Variable	`suspends`	Undocumented
Instance Variable	`attempt`	Undocumented
Instance Variable	`ctx`	Undocumented
Instance Variable	`encoder`	Undocumented
Instance Variable	`promise`	Undocumented
Instance Variable	`result`	Undocumented
Instance Variable	`retry_policy`	Undocumented
Instance Variable	`timeout`	Undocumented

def __post_init__(self): ¶

Undocumented

def __repr__(self) -> str: ¶

Undocumented

def map(self, *, attempt: int | None = None, promise: DurablePromise | None = None, result: Result[Any] | None = None, suspends: Node[State] | None = None) -> Lfnc: ¶

Undocumented

args: tuple[Any, ...] = ¶

Undocumented

ccls: Callable[[str, str, Info], Context] = ¶

Undocumented

cid: str = ¶

Undocumented

conv: Convention = ¶

Undocumented

func: Callable[..., Any] = ¶

Undocumented

id: str = ¶

Undocumented

kwargs: dict[str, Any] = ¶

Undocumented

opts: Options = ¶

Undocumented

suspends: list[Node[State]] = ¶

Undocumented

attempt: int = ¶

Undocumented

ctx: Context = ¶

Undocumented

encoder: Encoder[Any, tuple[dict[str, str] | None, str | None]] = ¶

Undocumented

promise: DurablePromise | None = ¶

Undocumented

result: Result[Any] | None = ¶

Undocumented

retry_policy: RetryPolicy = ¶

Undocumented

timeout: float = ¶

Undocumented