resonate.stores.traits.IPromiseStore

class documentation

class IPromiseStore(ABC):

Known subclasses: resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

View In Hierarchy

Undocumented

Method cancel Undocumented
Method create Undocumented
Method create_with_task Undocumented
Method get Undocumented
Method reject Undocumented
Method resolve Undocumented
@abstractmethod
def cancel(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented

@abstractmethod
def create(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags) -> DurablePromiseRecord:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented

@abstractmethod
def create_with_task(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags, pid: str, ttl: int) -> tuple[DurablePromiseRecord, TaskRecord | None]:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented

@abstractmethod
def get(self, *, id: str) -> DurablePromiseRecord:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented

@abstractmethod
def reject(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented

@abstractmethod
def resolve(self, *, id: str, ikey: IdempotencyKey, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overridden in resonate.stores.local.LocalPromiseStore, resonate.stores.remote.RemotePromiseStore

Undocumented