resonate.record.Record

class documentation

class Record(Generic[T]):

Constructor: Record(id, invocation, parent, ctx)

Undocumented

Method	`__init__`	Undocumented
Method	`add_child`	Undocumented
Method	`add_coro`	Undocumented
Method	`add_durable_promise`	Undocumented
Method	`add_task`	Undocumented
Method	`clear_coro`	Undocumented
Method	`create_child`	Undocumented
Method	`done`	Undocumented
Method	`get_coro`	Undocumented
Method	`get_task`	Undocumented
Method	`has_coro`	Undocumented
Method	`has_task`	Undocumented
Method	`increate_attempt`	Undocumented
Method	`next_child_name`	Undocumented
Method	`next_retry_delay`	Undocumented
Method	`remove_task`	Undocumented
Method	`root`	Undocumented
Method	`safe_result`	Undocumented
Method	`set_result`	Undocumented
Method	`should_retry`	Undocumented
Instance Variable	`blocked_on`	Undocumented
Instance Variable	`children`	Undocumented
Instance Variable	`ctx`	Undocumented
Instance Variable	`durable_promise`	Undocumented
Instance Variable	`id`	Undocumented
Instance Variable	`invocation`	Undocumented
Instance Variable	`is_root`	Undocumented
Instance Variable	`parent`	Undocumented
Instance Variable	`retry_policy`	Undocumented
Instance Variable	`_attempt`	Undocumented
Instance Variable	`_coro`	Undocumented
Instance Variable	`_num_children`	Undocumented
Instance Variable	`_result`	Undocumented
Instance Variable	`_task`	Undocumented

def __init__(self, id: str, invocation: LFI | RFI, parent: Record[Any] | None, ctx: Context): ¶

Undocumented

def add_child(self, record: Record[Any]): ¶

Undocumented

def add_coro(self, coro: ResonateCoro[T]): ¶

Undocumented

def add_durable_promise(self, durable_promise: DurablePromiseRecord): ¶

Undocumented

def add_task(self, task: TaskRecord): ¶

Undocumented

def clear_coro(self): ¶

Undocumented

def create_child(self, id: str, invocation: LFI | RFI) -> Record[Any]: ¶

Undocumented

def done(self) -> bool: ¶

Undocumented

def get_coro(self) -> ResonateCoro[T]: ¶

Undocumented

def get_task(self) -> TaskRecord: ¶

Undocumented

def has_coro(self) -> bool: ¶

Undocumented

def has_task(self) -> bool: ¶

Undocumented

def increate_attempt(self): ¶

Undocumented

def next_child_name(self) -> str: ¶

Undocumented

def next_retry_delay(self) -> float: ¶

Undocumented

def remove_task(self): ¶

Undocumented

def root(self) -> Record[Any]: ¶

Undocumented

def safe_result(self) -> Result[Any, Exception]: ¶

Undocumented

def set_result(self, result: Result[T, Exception], *, deduping: bool): ¶

Undocumented

def should_retry(self, result: Result[T, Exception]) -> bool: ¶

Undocumented

blocked_on: Record[Any] | None = ¶

Undocumented

children: list[Record[Any]] = ¶

Undocumented

ctx = ¶

Undocumented

durable_promise: DurablePromiseRecord | None = ¶

Undocumented

id: str = ¶

Undocumented

invocation: LFI | RFI = ¶

Undocumented

is_root: bool = ¶

Undocumented

parent: Record[Any] | None = ¶

Undocumented

retry_policy: retry_policy.RetryPolicy | None = ¶

Undocumented

_attempt: int = ¶

Undocumented

_coro: ResonateCoro[T] | None = ¶

Undocumented

_num_children: int = ¶

Undocumented

_result: Result[T, Exception] | None = ¶

Undocumented

_task: TaskRecord | None = ¶

Undocumented