resonate.models.durable_promise.DurablePromise

class documentation

class DurablePromise:

Constructor: DurablePromise.from_dict(store, data)

Undocumented

Class Method	`from_dict`	Undocumented
Method	`callback`	Undocumented
Method	`cancel`	Undocumented
Method	`reject`	Undocumented
Method	`resolve`	Undocumented
Method	`result`	Undocumented
Method	`subscribe`	Undocumented
Class Variable	`created_on`	Undocumented
Class Variable	`id`	Undocumented
Class Variable	`ikey_for_create`	Undocumented
Class Variable	`param`	Undocumented
Class Variable	`store`	Undocumented
Class Variable	`tags`	Undocumented
Class Variable	`timeout`	Undocumented
Instance Variable	`completed_on`	Undocumented
Instance Variable	`ikey_for_complete`	Undocumented
Instance Variable	`state`	Undocumented
Instance Variable	`value`	Undocumented
Property	`abs_timeout`	Undocumented
Property	`canceled`	Undocumented
Property	`completed`	Undocumented
Property	`pending`	Undocumented
Property	`rejected`	Undocumented
Property	`rel_timeout`	Undocumented
Property	`resolved`	Undocumented
Property	`timedout`	Undocumented
Method	`_complete`	Undocumented

@classmethod

def from_dict(cls, store: Store, data: Mapping[str, Any]) -> DurablePromise: ¶

Undocumented

def callback(self, id: str, root_promise_id: str, recv: str) -> Callback | None: ¶

Undocumented

def cancel(self, data: str | None, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None): ¶

Undocumented

def reject(self, data: str | None, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None): ¶

Undocumented

def resolve(self, data: str | None, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None): ¶

Undocumented

def result(self, encoder: Encoder[Any, tuple[dict[str, str] | None, str | None]]) -> Result[Any]: ¶

Undocumented

def subscribe(self, id: str, recv: str) -> Callback | None: ¶

Undocumented

created_on: int = ¶

Undocumented

id: str = ¶

Undocumented

ikey_for_create: str | None = ¶

Undocumented

param: DurablePromiseValue = ¶

Undocumented

store: Store = ¶

Undocumented

tags: dict[str, str] = ¶

Undocumented

timeout: int = ¶

Undocumented

completed_on: int | None = ¶

Undocumented

ikey_for_complete: str | None = ¶

Undocumented

state: Literal['PENDING', 'RESOLVED', 'REJECTED', 'REJECTED_CANCELED', 'REJECTED_TIMEDOUT'] = ¶

Undocumented

value: DurablePromiseValue = ¶

Undocumented

@property

abs_timeout: float = ¶

Undocumented

@property

canceled: bool = ¶

Undocumented

@property

completed: bool = ¶

Undocumented

@property

pending: bool = ¶

Undocumented

@property

rejected: bool = ¶

Undocumented

@property

rel_timeout: float = ¶

Undocumented

@property

resolved: bool = ¶

Undocumented

@property

timedout: bool = ¶

Undocumented

def _complete(self, promise: DurablePromise): ¶

Undocumented