resonate.scheduler.Coro

class documentation

class Coro:

View In Hierarchy

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 coro Undocumented
Instance Variable ctx Undocumented
Instance Variable encoder Undocumented
Instance Variable next 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, next: AWT | Result[Any] | None = None, promise: DurablePromise | None = None, result: Result[Any] | None = None, suspends: Node[State] | None = None, timeout: float | None = None) -> Coro:

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

coro: Coroutine =

Undocumented

ctx: Context =

Undocumented

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

Undocumented

next: None | AWT | Result[Any] =

Undocumented

promise: DurablePromise | None =

Undocumented

result: Result[Any] | None =

Undocumented

retry_policy =

Undocumented

timeout: float =

Undocumented