resonate.stores.remote.RemotePromiseStore

class documentation

class RemotePromiseStore:

Constructor: RemotePromiseStore(store)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method callback Undocumented
Method cancel Undocumented
Method create Undocumented
Method create_with_task Undocumented
Method get Undocumented
Method reject Undocumented
Method resolve Undocumented
Method subscribe Undocumented
Method _headers Undocumented
Instance Variable _store Undocumented
def __init__(self, store: RemoteStore):

Undocumented

def callback(self, promise_id: str, root_promise_id: str, recv: str, timeout: int) -> tuple[DurablePromise, Callback | None]:

Undocumented

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

Undocumented

def create(self, id: str, timeout: int, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: str | None = None, tags: dict[str, str] | None = None) -> DurablePromise:

Undocumented

def create_with_task(self, id: str, timeout: int, pid: str, ttl: int, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: str | None = None, tags: dict[str, str] | None = None) -> tuple[DurablePromise, Task | None]:

Undocumented

def get(self, id: str) -> DurablePromise:

Undocumented

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

Undocumented

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

Undocumented

def subscribe(self, id: str, promise_id: str, recv: str, timeout: int) -> tuple[DurablePromise, Callback | None]:

Undocumented

def _headers(self, *, strict: bool, ikey: str | None) -> dict[str, str]:

Undocumented

_store =

Undocumented