resonate.models.store.PromiseStore

class documentation

class PromiseStore(Protocol):

View In Hierarchy

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
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